HadoopFormatIO
instead.@Deprecated public abstract static class HadoopInputFormatIO.Read<K,V> extends PTransform<PBegin,PCollection<KV<K,V>>>
name
Constructor and Description |
---|
Read()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
PCollection<KV<K,V>> |
expand(PBegin input)
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#expand(PBegin) instead. |
SerializableConfiguration |
getConfiguration()
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#getConfiguration() instead. |
protected abstract HadoopFormatIO.Read<K,V> |
getHFIORead()
Deprecated.
|
TypeDescriptor<?> |
getinputFormatClass()
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#getinputFormatClass()
instead. |
TypeDescriptor<?> |
getinputFormatKeyClass()
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#getinputFormatKeyClass()
instead. |
TypeDescriptor<?> |
getinputFormatValueClass()
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#getinputFormatValueClass()
instead. |
SimpleFunction<?,K> |
getKeyTranslationFunction()
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#getKeyTranslationFunction()
instead. |
TypeDescriptor<K> |
getKeyTypeDescriptor()
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#getKeyTypeDescriptor()
instead. |
SimpleFunction<?,V> |
getValueTranslationFunction()
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#getValueTranslationFunction()
instead. |
TypeDescriptor<V> |
getValueTypeDescriptor()
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#getValueTypeDescriptor()
instead. |
HadoopInputFormatIO.Read<K,V> |
withConfiguration(org.apache.hadoop.conf.Configuration configuration)
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#withConfiguration(Configuration) instead. |
HadoopInputFormatIO.Read<K,V> |
withKeyTranslation(SimpleFunction<?,K> function)
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#withKeyTranslation(SimpleFunction) instead. |
HadoopInputFormatIO.Read<K,V> |
withValueTranslation(SimpleFunction<?,V> function)
Deprecated.
as of version 2.10. Use
HadoopFormatIO.Read#withValueTranslation(SimpleFunction) instead. |
compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString, validate
protected abstract HadoopFormatIO.Read<K,V> getHFIORead()
@Deprecated @Nullable public SerializableConfiguration getConfiguration()
HadoopFormatIO.Read#getConfiguration()
instead.@Deprecated @Nullable public SimpleFunction<?,K> getKeyTranslationFunction()
HadoopFormatIO.Read#getKeyTranslationFunction()
instead.@Deprecated @Nullable public SimpleFunction<?,V> getValueTranslationFunction()
HadoopFormatIO.Read#getValueTranslationFunction()
instead.@Deprecated @Nullable public TypeDescriptor<K> getKeyTypeDescriptor()
HadoopFormatIO.Read#getKeyTypeDescriptor()
instead.@Deprecated @Nullable public TypeDescriptor<V> getValueTypeDescriptor()
HadoopFormatIO.Read#getValueTypeDescriptor()
instead.@Deprecated @Nullable public TypeDescriptor<?> getinputFormatClass()
HadoopFormatIO.Read#getinputFormatClass()
instead.@Deprecated @Nullable public TypeDescriptor<?> getinputFormatKeyClass()
HadoopFormatIO.Read#getinputFormatKeyClass()
instead.@Deprecated @Nullable public TypeDescriptor<?> getinputFormatValueClass()
HadoopFormatIO.Read#getinputFormatValueClass()
instead.@Deprecated public HadoopInputFormatIO.Read<K,V> withConfiguration(org.apache.hadoop.conf.Configuration configuration)
HadoopFormatIO.Read#withConfiguration(Configuration)
instead.@Deprecated public HadoopInputFormatIO.Read<K,V> withKeyTranslation(SimpleFunction<?,K> function)
HadoopFormatIO.Read#withKeyTranslation(SimpleFunction)
instead.@Deprecated public HadoopInputFormatIO.Read<K,V> withValueTranslation(SimpleFunction<?,V> function)
HadoopFormatIO.Read#withValueTranslation(SimpleFunction)
instead.@Deprecated public PCollection<KV<K,V>> expand(PBegin input)
HadoopFormatIO.Read#expand(PBegin)
instead.PTransform
PTransform
should be expanded on the given
InputT
.
NOTE: This method should not be called directly. Instead apply the PTransform
should
be applied to the InputT
using the apply
method.
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).
expand
in class PTransform<PBegin,PCollection<KV<K,V>>>