org.apache.kylin.common.util.Dictionary.getMinId()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(7.1k)|赞(0)|评价(0)|浏览(156)

本文整理了Java中org.apache.kylin.common.util.Dictionary.getMinId()方法的一些代码示例,展示了Dictionary.getMinId()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Dictionary.getMinId()方法的具体详情如下:
包路径:org.apache.kylin.common.util.Dictionary
类名称:Dictionary
方法名:getMinId

Dictionary.getMinId介绍

暂无

代码示例

代码示例来源:origin: apache/kylin

  1. public int getSize() {
  2. return getMaxId() - getMinId() + 1;
  3. }

代码示例来源:origin: apache/kylin

  1. public MultipleDictionaryValueEnumerator(DataType dataType, List<DictionaryInfo> dictionaryInfoList) {
  2. this.dataType = dataType;
  3. dictionaryList = Lists.newArrayListWithCapacity(dictionaryInfoList.size());
  4. for (DictionaryInfo dictInfo : dictionaryInfoList) {
  5. Dictionary<String> dictionary = (Dictionary<String>) dictInfo.getDictionaryObject();
  6. dictionaryList.add((Dictionary<String>) dictInfo.getDictionaryObject());
  7. curKeys.add(dictionary.getMinId());
  8. }
  9. }

代码示例来源:origin: apache/kylin

  1. public List<T> enumeratorValues() {
  2. List<T> ret = Lists.newArrayListWithExpectedSize(getSize());
  3. for (int i = getMinId(); i <= getMaxId(); i++) {
  4. ret.add(getValueFromId(i));
  5. }
  6. return ret;
  7. }

代码示例来源:origin: apache/kylin

  1. public ShrunkenDictionary<T> build(ValueSerializer<T> valueSerializer) {
  2. return new ShrunkenDictionary<>(valueSerializer, fullDict.getMinId(), fullDict.getMaxId(),
  3. fullDict.getSizeOfId(), fullDict.getSizeOfValue(), valueToIdMap);
  4. }
  5. }

代码示例来源:origin: apache/kylin

  1. @Override
  2. public boolean contains(Dictionary other) {
  3. if (other.getSize() > this.getSize()) {
  4. return false;
  5. }
  6. for (int i = other.getMinId(); i <= other.getMaxId(); ++i) {
  7. T v = (T) other.getValueFromId(i);
  8. if (!this.containsValue(v)) {
  9. return false;
  10. }
  11. }
  12. return true;
  13. }

代码示例来源:origin: apache/kylin

  1. @Override
  2. public boolean contains(Dictionary other) {
  3. if (other.getSize() > this.getSize()) {
  4. return false;
  5. }
  6. for (int i = other.getMinId(); i <= other.getMaxId(); ++i) {
  7. T v = (T) other.getValueFromId(i);
  8. if (!this.containsValue(v)) {
  9. return false;
  10. }
  11. }
  12. return true;
  13. }

代码示例来源:origin: apache/kylin

  1. for (int i = dict.getMinId(); i <= dict.getMaxId(); i++) {
  2. Object dictVal = dict.getValueFromId(i);
  3. Object computedVal = builtInFunctionTupleFilter.invokeFunction(dictVal);

代码示例来源:origin: apache/kylin

  1. private TupleFilter translateFunctionTupleFilter(BuiltInFunctionTupleFilter builtInFunctionTupleFilter) {
  2. if (!builtInFunctionTupleFilter.isValid())
  3. return null;
  4. TblColRef columnRef = builtInFunctionTupleFilter.getColumn();
  5. Dictionary<?> dict = dimEncMap.getDictionary(columnRef);
  6. if (dict == null)
  7. return null;
  8. CompareTupleFilter translated = new CompareTupleFilter(builtInFunctionTupleFilter.isReversed() ? FilterOperatorEnum.NOTIN : FilterOperatorEnum.IN);
  9. translated.addChild(new ColumnTupleFilter(columnRef));
  10. try {
  11. int translatedInClauseMaxSize = KylinConfig.getInstanceFromEnv().getTranslatedInClauseMaxSize();
  12. for (int i = dict.getMinId(); i <= dict.getMaxId(); i++) {
  13. Object dictVal = dict.getValueFromId(i);
  14. if ((Boolean) builtInFunctionTupleFilter.invokeFunction(dictVal)) {
  15. translated.addChild(new ConstantTupleFilter(dictVal));
  16. if (translated.getChildren().size() > translatedInClauseMaxSize) {
  17. return null;
  18. }
  19. }
  20. }
  21. logger.debug("getting a in clause with {} children", translated.getChildren().size());
  22. } catch (Exception e) {
  23. logger.debug(e.getMessage());
  24. return null;
  25. }
  26. return translated;
  27. }

代码示例来源:origin: org.apache.kylin/kylin-dictionary

  1. public MultipleDictionaryValueEnumerator(List<DictionaryInfo> dictionaryInfoList) {
  2. dictionaryList = Lists.newArrayListWithCapacity(dictionaryInfoList.size());
  3. for (DictionaryInfo dictInfo : dictionaryInfoList) {
  4. dictionaryList.add(dictInfo.getDictionaryObject());
  5. }
  6. if (!dictionaryList.isEmpty()) {
  7. curDict = dictionaryList.get(0);
  8. curKey = curDict.getMinId();
  9. }
  10. }

代码示例来源:origin: org.apache.kylin/kylin-core-common

  1. public int getSize() {
  2. return getMaxId() - getMinId() + 1;
  3. }

代码示例来源:origin: org.apache.kylin/kylin-common

  1. public int getSize() {
  2. return getMaxId() - getMinId() + 1;
  3. }

代码示例来源:origin: org.apache.kylin/kylin-core-dictionary

  1. public MultipleDictionaryValueEnumerator(DataType dataType, List<DictionaryInfo> dictionaryInfoList) {
  2. this.dataType = dataType;
  3. dictionaryList = Lists.newArrayListWithCapacity(dictionaryInfoList.size());
  4. for (DictionaryInfo dictInfo : dictionaryInfoList) {
  5. Dictionary<String> dictionary = (Dictionary<String>) dictInfo.getDictionaryObject();
  6. dictionaryList.add((Dictionary<String>) dictInfo.getDictionaryObject());
  7. curKeys.add(dictionary.getMinId());
  8. }
  9. }

代码示例来源:origin: org.apache.kylin/kylin-core-common

  1. public List<T> enumeratorValues() {
  2. List<T> ret = Lists.newArrayListWithExpectedSize(getSize());
  3. for (int i = getMinId(); i <= getMaxId(); i++) {
  4. ret.add(getValueFromId(i));
  5. }
  6. return ret;
  7. }

代码示例来源:origin: org.apache.kylin/kylin-dictionary

  1. @Override
  2. public boolean moveNext() throws IOException {
  3. if (curDictIndex < dictionaryList.size() && curKey <= curDict.getMaxId()) {
  4. byte[] buffer = new byte[curDict.getSizeOfValue()];
  5. int size = curDict.getValueBytesFromId(curKey, buffer, 0);
  6. curValue = Bytes.copy(buffer, 0, size);
  7. if (++curKey > curDict.getMaxId()) {
  8. if (++curDictIndex < dictionaryList.size()) {
  9. curDict = dictionaryList.get(curDictIndex);
  10. curKey = curDict.getMinId();
  11. }
  12. }
  13. return true;
  14. }
  15. curValue = null;
  16. return false;
  17. }

代码示例来源:origin: org.apache.kylin/kylin-core-dictionary

  1. public ShrunkenDictionary<T> build(ValueSerializer<T> valueSerializer) {
  2. return new ShrunkenDictionary<>(valueSerializer, fullDict.getMinId(), fullDict.getMaxId(),
  3. fullDict.getSizeOfId(), fullDict.getSizeOfValue(), valueToIdMap);
  4. }
  5. }

代码示例来源:origin: org.apache.kylin/kylin-core-dictionary

  1. @Override
  2. public boolean contains(Dictionary other) {
  3. if (other.getSize() > this.getSize()) {
  4. return false;
  5. }
  6. for (int i = other.getMinId(); i <= other.getMaxId(); ++i) {
  7. T v = (T) other.getValueFromId(i);
  8. if (!this.containsValue(v)) {
  9. return false;
  10. }
  11. }
  12. return true;
  13. }

代码示例来源:origin: org.apache.kylin/kylin-core-dictionary

  1. @Override
  2. public boolean contains(Dictionary other) {
  3. if (other.getSize() > this.getSize()) {
  4. return false;
  5. }
  6. for (int i = other.getMinId(); i <= other.getMaxId(); ++i) {
  7. T v = (T) other.getValueFromId(i);
  8. if (!this.containsValue(v)) {
  9. return false;
  10. }
  11. }
  12. return true;
  13. }

代码示例来源:origin: org.apache.kylin/kylin-core-dictionary

  1. private TupleFilter translateFunctionTupleFilter(BuiltInFunctionTupleFilter builtInFunctionTupleFilter) {
  2. if (!builtInFunctionTupleFilter.isValid())
  3. return null;
  4. TblColRef columnRef = builtInFunctionTupleFilter.getColumn();
  5. Dictionary<?> dict = dimEncMap.getDictionary(columnRef);
  6. if (dict == null)
  7. return null;
  8. CompareTupleFilter translated = new CompareTupleFilter(builtInFunctionTupleFilter.isReversed() ? FilterOperatorEnum.NOTIN : FilterOperatorEnum.IN);
  9. translated.addChild(new ColumnTupleFilter(columnRef));
  10. try {
  11. int translatedInClauseMaxSize = KylinConfig.getInstanceFromEnv().getTranslatedInClauseMaxSize();
  12. for (int i = dict.getMinId(); i <= dict.getMaxId(); i++) {
  13. Object dictVal = dict.getValueFromId(i);
  14. if ((Boolean) builtInFunctionTupleFilter.invokeFunction(dictVal)) {
  15. translated.addChild(new ConstantTupleFilter(dictVal));
  16. if (translated.getChildren().size() > translatedInClauseMaxSize) {
  17. return null;
  18. }
  19. }
  20. }
  21. logger.debug("getting a in clause with {} children", translated.getChildren().size());
  22. } catch (Exception e) {
  23. logger.debug(e.getMessage());
  24. return null;
  25. }
  26. return translated;
  27. }

代码示例来源:origin: org.apache.kylin/kylin-core-dictionary

  1. for (int i = dict.getMinId(); i <= dict.getMaxId(); i++) {
  2. Object dictVal = dict.getValueFromId(i);
  3. Object computedVal = builtInFunctionTupleFilter.invokeFunction(dictVal);

相关文章