public interface ReadableSource<T> extends Source<T>
Sourceinterface that indicates that a
Sourceinstance may be read as a series of records by the client code. This is used to determine whether a
PCollectioninstance can be materialized.
|Modifier and Type||Method and Description|
Iterable<T> read(org.apache.hadoop.conf.Configuration conf) throws IOException
Iterablethat contains the contents of this source.
conf- The current
Copyright © 2017 The Apache Software Foundation. All rights reserved.