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

TypeDescriptor.of介绍

[英]Returns a TypeDescriptor representing the given type.
[中]返回表示给定类型的TypeDescriptor。

代码示例

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

@Override
public TypeDescriptor<T> getEncodedTypeDescriptor() {
 if (typeDescriptor == null) {
  typeDescriptor = TypeDescriptor.of(type);
 }
 return typeDescriptor;
}

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

/**
 * Registers the provided {@link Coder} for the given class.
 *
 * <p>Note that this is equivalent to {@code registerCoderForType(TypeDescriptor.of(clazz))}. See
 * {@link #registerCoderForType(TypeDescriptor, Coder)} for further details.
 */
public void registerCoderForClass(Class<?> clazz, Coder<?> coder) {
 registerCoderForType(TypeDescriptor.of(clazz), coder);
}

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

/**
 * Get a schema for a given {@link Class} type. If no schema exists, throws {@link
 * NoSuchSchemaException}.
 */
public <T> Schema getSchema(Class<T> clazz) throws NoSuchSchemaException {
 return getSchema(TypeDescriptor.of(clazz));
}

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

/** Rerieve the function that converts an object of the specified type to a {@link Row} object. */
public <T> SerializableFunction<T, Row> getToRowFunction(Class<T> clazz)
  throws NoSuchSchemaException {
 return getToRowFunction(TypeDescriptor.of(clazz));
}

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

/**
 * Register a POJO type for automatic schema inference.
 *
 * <p>Currently schema field names will match field names in the POJO, and all fields must be
 * mutable (i.e. no final fields).
 */
public <T> void registerPOJO(Class<T> clazz) {
 registerPOJO(TypeDescriptor.of(clazz));
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

@Override
 public List<CoderProvider> getCoderProviders() {
  return ImmutableList.of(
    CoderProviders.forCoder(
      TypeDescriptor.of(PubsubMessage.class), PubsubMessageWithAttributesCoder.of()));
 }
}

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

/**
 * Returns a {@link SerializableCoder} instance for the provided element class.
 *
 * @param <T> the element type
 */
public static <T extends Serializable> SerializableCoder<T> of(Class<T> clazz) {
 checkEqualsMethodDefined(clazz);
 return new SerializableCoder<>(clazz, TypeDescriptor.of(clazz));
}

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

@VisibleForTesting
static DoFnSignature.GetRestrictionCoderMethod analyzeGetRestrictionCoderMethod(
  ErrorReporter errors, TypeDescriptor<? extends DoFn> fnT, Method m) {
 errors.checkArgument(m.getParameterTypes().length == 0, "Must have zero arguments");
 TypeDescriptor<?> resT = fnT.resolveType(m.getGenericReturnType());
 errors.checkArgument(
   resT.isSubtypeOf(TypeDescriptor.of(Coder.class)),
   "Must return a Coder, but returns %s",
   formatType(resT));
 return DoFnSignature.GetRestrictionCoderMethod.create(m, resT);
}

代码示例来源：origin: GoogleCloudPlatform/java-docs-samples

public static void main(String[] args) {
 Options options = PipelineOptionsFactory.fromArgs(args).withValidation().as(Options.class);
 Pipeline p = Pipeline.create(options);
 SpannerConfig spannerConfig = SpannerConfig.create()
   .withInstanceId(options.getInstanceId())
   .withDatabaseId(options.getDatabaseId());
 // [START spanner_dataflow_readall]
 PCollection<Struct> allRecords = p.apply(SpannerIO.read()
   .withSpannerConfig(spannerConfig)
   .withQuery("SELECT t.table_name FROM information_schema.tables AS t WHERE t"
     + ".table_catalog = '' AND t.table_schema = ''")).apply(
   MapElements.into(TypeDescriptor.of(ReadOperation.class))
     .via((SerializableFunction<Struct, ReadOperation>) input -> {
      String tableName = input.getString(0);
      return ReadOperation.create().withQuery("SELECT * FROM " + tableName);
     })).apply(SpannerIO.readAll().withSpannerConfig(spannerConfig));
 // [END spanner_dataflow_readall]
 PCollection<Long> dbEstimatedSize = allRecords.apply(EstimateSize.create())
   .apply(Sum.longsGlobally());
 dbEstimatedSize.apply(ToString.elements()).apply(TextIO.write().to(options.getOutput())
   .withoutSharding());
 p.run().waitUntilFinish();
}

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

@Override
 public List<CoderProvider> getCoderProviders() {
  return ImmutableList.of(
    CoderProviders.forCoder(TypeDescriptor.of(ByteString.class), ByteStringCoder.of()),
    ProtoCoder.getCoderProvider());
 }
}

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

/**
 * A more general form of {@link #where(TypeParameter, TypeDescriptor)} that returns a new {@code
 * TypeDescriptor} by matching {@code formal} against {@code actual} to resolve type variables in
 * the current {@link TypeDescriptor}.
 */
@SuppressWarnings("unchecked")
public TypeDescriptor<T> where(Type formal, Type actual) {
 TypeResolver resolver = new TypeResolver().where(formal, actual);
 return (TypeDescriptor<T>) TypeDescriptor.of(resolver.resolveType(token.getType()));
}

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

@Override
 public List<CoderProvider> getCoderProviders() {
  return ImmutableList.of(
    CoderProviders.forCoder(TypeDescriptor.of(MyValueB.class), MyValueBCoder.INSTANCE));
 }
}

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

@Test
 public void testEncodedTypeDescriptor() throws Exception {
  assertThat(TEST_CODER.getEncodedTypeDescriptor(), equalTo(TypeDescriptor.of(byte[].class)));
 }
}

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

@Test
 public void testEncodedTypeDescriptor() throws Exception {
  assertThat(
    TEST_CODER.getEncodedTypeDescriptor(), equalTo(TypeDescriptor.of(ReadableDuration.class)));
 }
}

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

@Test
 public void testEncodedTypeDescriptor() throws Exception {
  assertThat(TEST_CODER.getEncodedTypeDescriptor(), equalTo(TypeDescriptor.of(Integer.class)));
 }
}

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

@Test
public void testEncodedTypeDescriptor() throws Exception {
 AvroCoder<Pojo> coder = AvroCoder.of(Pojo.class);
 assertThat(coder.getEncodedTypeDescriptor(), equalTo(TypeDescriptor.of(Pojo.class)));
}

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

@Test
 public void testUnknown() throws Exception {
  thrown.expect(CannotProvideCoderException.class);
  new DefaultCoderProvider().coderFor(TypeDescriptor.of(Unknown.class), Collections.emptyList());
 }
}

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

@Test
public void testEncodedTypeDescriptor() throws Exception {
 assertThat(
   SerializableCoder.of(MyRecord.class).getEncodedTypeDescriptor(),
   Matchers.equalTo(TypeDescriptor.of(MyRecord.class)));
}

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

/**
 * Tests that the error message for a type variable includes a mention of where the type variable
 * was declared.
 */
@Test
public void testTypeVariableErrorMessage() throws Exception {
 CoderRegistry registry = CoderRegistry.createDefault();
 thrown.expect(CannotProvideCoderException.class);
 thrown.expectMessage("Unable to provide a Coder");
 registry.getCoder(TypeDescriptor.of(TestGenericClass.class.getTypeParameters()[0]));
}

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

@Test
public void testNewTrackerWrongNumArguments() throws Exception {
 thrown.expectMessage("Must have a single argument");
 DoFnSignatures.analyzeNewTrackerMethod(
   errors(),
   TypeDescriptor.of(FakeDoFn.class),
   new AnonymousMethod() {
    private SomeRestrictionTracker method(SomeRestriction restriction, Object extra) {
     return null;
    }
   }.getMethod());
}