org.apache.beam.sdk.values.TypeDescriptor.equals()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(68)

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

TypeDescriptor.equals介绍

[英]Two type descriptor are equal if and only if they represent the same type.
[中]当且仅当两个类型描述符表示同一类型时，它们才相等。

代码示例

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
public <T> Coder<T> coderFor(TypeDescriptor<T> type, List<? extends Coder<?>> componentCoders)
  throws CannotProvideCoderException {
 if (!this.type.equals(type)) {
  throw new CannotProvideCoderException(
    String.format(
      "Unable to provide coder for %s, this factory can only provide coders for %s",
      type, this.type));
 }
 return (Coder) coder;
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-hadoop-format

/** Validates translation function given for key/value translation. */
private void validateTranslationFunction(
  TypeDescriptor<?> inputType, SimpleFunction<?, ?> simpleFunction, String errorMsg) {
 if (simpleFunction != null && !simpleFunction.getInputTypeDescriptor().equals(inputType)) {
  throw new IllegalArgumentException(
    String.format(errorMsg, getinputFormatClass().getRawType(), inputType.getRawType()));
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-hadoop-input-format

/** Validates translation function given for key/value translation. */
private void validateTranslationFunction(
  TypeDescriptor<?> inputType, SimpleFunction<?, ?> simpleFunction, String errorMsg) {
 if (simpleFunction != null && !simpleFunction.getInputTypeDescriptor().equals(inputType)) {
  throw new IllegalArgumentException(
    String.format(errorMsg, getinputFormatClass().getRawType(), inputType.getRawType()));
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
public <T> Schema schemaFor(TypeDescriptor<T> typeDescriptor) {
 if (typeDescriptor.equals(TypeDescriptor.of(TestDefaultSchemaClass.class))) {
  return EMPTY_SCHEMA;
 }
 return null;
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@VisibleForTesting
static DoFnSignature.GetInitialRestrictionMethod analyzeGetInitialRestrictionMethod(
  ErrorReporter errors,
  TypeDescriptor<? extends DoFn> fnT,
  Method m,
  TypeDescriptor<?> inputT) {
 // Method is of the form:
 // @GetInitialRestriction
 // RestrictionT getInitialRestriction(InputT element);
 Type[] params = m.getGenericParameterTypes();
 errors.checkArgument(
   params.length == 1 && fnT.resolveType(params[0]).equals(inputT),
   "Must take a single argument of type %s",
   formatType(inputT));
 return DoFnSignature.GetInitialRestrictionMethod.create(
   m, fnT.resolveType(m.getGenericReturnType()));
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
public <T> Schema schemaFor(TypeDescriptor<T> typeDescriptor) {
 if (typeDescriptor.equals(TypeDescriptor.of(TestSchemaClass.class))) {
  return EMPTY_SCHEMA;
 }
 return null;
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@VisibleForTesting
static DoFnSignature.BundleMethod analyzeStartBundleMethod(
  ErrorReporter errors,
  TypeDescriptor<? extends DoFn<?, ?>> fnT,
  Method m,
  TypeDescriptor<?> inputT,
  TypeDescriptor<?> outputT) {
 errors.checkArgument(void.class.equals(m.getReturnType()), "Must return void");
 TypeDescriptor<?> expectedContextT = doFnStartBundleContextTypeOf(inputT, outputT);
 Type[] params = m.getGenericParameterTypes();
 errors.checkArgument(
   params.length == 0
     || (params.length == 1 && fnT.resolveType(params[0]).equals(expectedContextT)),
   "Must take a single argument of type %s",
   formatType(expectedContextT));
 return DoFnSignature.BundleMethod.create(m);
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
public <T> Schema schemaFor(TypeDescriptor<T> typeDescriptor) {
 if (typeDescriptor.equals(TypeDescriptors.strings())) {
  return STRING_SCHEMA;
 } else if (typeDescriptor.equals(TypeDescriptors.integers())) {
  return INTEGER_SCHEMA;
 } else {
  return null;
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@VisibleForTesting
static DoFnSignature.BundleMethod analyzeFinishBundleMethod(
  ErrorReporter errors,
  TypeDescriptor<? extends DoFn<?, ?>> fnT,
  Method m,
  TypeDescriptor<?> inputT,
  TypeDescriptor<?> outputT) {
 errors.checkArgument(void.class.equals(m.getReturnType()), "Must return void");
 TypeDescriptor<?> expectedContextT = doFnFinishBundleContextTypeOf(inputT, outputT);
 Type[] params = m.getGenericParameterTypes();
 errors.checkArgument(
   params.length == 0
     || (params.length == 1 && fnT.resolveType(params[0]).equals(expectedContextT)),
   "Must take a single argument of type %s",
   formatType(expectedContextT));
 return DoFnSignature.BundleMethod.create(m);
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
 @SuppressWarnings("unchecked")
 public <T> SerializableFunction<Row, T> fromRowFunction(TypeDescriptor<T> typeDescriptor) {
  if (typeDescriptor.equals(TypeDescriptor.of(TestDefaultSchemaClass.class))) {
   return r -> (T) new TestSchemaClass();
  }
  return null;
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-hadoop-format

KV.class);
checkArgument(
  inputTypeDescriptor.equals(
    TypeDescriptors.kvs(outputFormatKeyClass, outputFormatValueClass)),
  "%s expects following %ss: KV(Key: %s, Value: %s) but following %ss are set: KV(Key: %s, Value: %s)",

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
 @SuppressWarnings("unchecked")
 public <T> SerializableFunction<Row, T> fromRowFunction(TypeDescriptor<T> typeDescriptor) {
  if (typeDescriptor.equals(TypeDescriptor.of(TestSchemaClass.class))) {
   return r -> (T) new TestSchemaClass();
  }
  return null;
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@VisibleForTesting
static DoFnSignature.SplitRestrictionMethod analyzeSplitRestrictionMethod(
  ErrorReporter errors,
  TypeDescriptor<? extends DoFn> fnT,
  Method m,
  TypeDescriptor<?> inputT) {
 // Method is of the form:
 // @SplitRestriction
 // void splitRestriction(InputT element, RestrictionT restriction);
 errors.checkArgument(void.class.equals(m.getReturnType()), "Must return void");
 Type[] params = m.getGenericParameterTypes();
 errors.checkArgument(params.length == 3, "Must have exactly 3 arguments");
 errors.checkArgument(
   fnT.resolveType(params[0]).equals(inputT),
   "First argument must be the element type %s",
   formatType(inputT));
 TypeDescriptor<?> restrictionT = fnT.resolveType(params[1]);
 TypeDescriptor<?> receiverT = fnT.resolveType(params[2]);
 TypeDescriptor<?> expectedReceiverT = outputReceiverTypeOf(restrictionT);
 errors.checkArgument(
   receiverT.equals(expectedReceiverT),
   "Third argument must be %s, but is %s",
   formatType(expectedReceiverT),
   formatType(receiverT));
 return DoFnSignature.SplitRestrictionMethod.create(m, restrictionT);
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
public <T> SerializableFunction<T, Row> toRowFunction(TypeDescriptor<T> typeDescriptor) {
 if (typeDescriptor.equals(TypeDescriptor.of(TestSchemaClass.class))) {
  return v -> Row.withSchema(EMPTY_SCHEMA).build();
 }
 return null;
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
public <T> SerializableFunction<T, Row> toRowFunction(TypeDescriptor<T> typeDescriptor) {
 if (typeDescriptor.equals(TypeDescriptor.of(TestDefaultSchemaClass.class))) {
  return v -> Row.withSchema(EMPTY_SCHEMA).build();
 }
 return null;
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

if (paramT.equals(TypeDescriptor.of(Row.class)) && !paramT.equals(inputT)) {
 } else {
  methodErrors.checkArgument(
    paramT.equals(inputT), "@Element argument must have type %s", inputT);
  return Parameter.elementParameter(paramT);
} else if (rawType.equals(DoFn.ProcessContext.class)) {
 paramErrors.checkArgument(
   paramT.equals(expectedProcessContextT),
   "ProcessContext argument must have type %s",
   formatType(expectedProcessContextT));
} else if (rawType.equals(DoFn.OnTimerContext.class)) {
 paramErrors.checkArgument(
   paramT.equals(expectedOnTimerContextT),
   "OnTimerContext argument must have type %s",
   formatType(expectedOnTimerContextT));
   paramT.equals(outputReceiverTypeOf(TypeDescriptor.of(Row.class)))
     && !outputT.equals(TypeDescriptor.of(Row.class));
 if (!schemaRowReceiver) {
  TypeDescriptor<?> expectedReceiverT = outputReceiverTypeOf(outputT);
  paramErrors.checkArgument(
    paramT.equals(expectedReceiverT),
    "OutputReceiver should be parameterized by %s",
    outputT);

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

TypeDescriptor<?> restrictionT = getInitialRestriction.restrictionT();
getInitialRestrictionErrors.checkArgument(
  restrictionT.equals(newTracker.restrictionT()),
  "Uses restriction type %s, but @%s method %s uses restriction type %s",
  formatType(restrictionT),
  splitRestriction.restrictionT().equals(restrictionT),
  "Uses restriction type %s, but @%s method %s uses restriction type %s",
  formatType(restrictionT),

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

boolean toRow = outputTypeDescriptor.equals(TypeDescriptor.of(Row.class));
if (toRow) {

内容来源于网络，如有侵权，请联系作者删除！

TypeDescriptor

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com