Package org.apache.beam.sdk.io.xml

Class XmlSource<T>

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData
    public class XmlSource<T>
extends org.apache.beam.sdk.io.FileBasedSource<T>
    Implementation of XmlIO.read().
    See Also:
    Serialized Form

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.beam.sdk.io.FileBasedSource

        org.apache.beam.sdk.io.FileBasedSource.FileBasedReader<T extends java.lang.Object>, org.apache.beam.sdk.io.FileBasedSource.Mode

      • Nested classes/interfaces inherited from class org.apache.beam.sdk.io.OffsetBasedSource

        org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader<T extends java.lang.Object>

      • Nested classes/interfaces inherited from class org.apache.beam.sdk.io.BoundedSource

        org.apache.beam.sdk.io.BoundedSource.BoundedReader<T extends java.lang.Object>

      • Nested classes/interfaces inherited from class org.apache.beam.sdk.io.Source

        org.apache.beam.sdk.io.Source.Reader<T extends java.lang.Object>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected org.apache.beam.sdk.io.FileBasedSource<T> createForSubrangeOfFile​(org.apache.beam.sdk.io.fs.MatchResult.Metadata metadata, long start, long end)  
      protected org.apache.beam.sdk.io.FileBasedSource.FileBasedReader<T> createSingleFileReader​(org.apache.beam.sdk.options.PipelineOptions options)  
      org.apache.beam.sdk.coders.Coder<T> getOutputCoder()  

      • Methods inherited from class org.apache.beam.sdk.io.FileBasedSource

        createReader, createSourceForSubrange, getEmptyMatchTreatment, getEstimatedSizeBytes, getFileOrPatternSpec, getFileOrPatternSpecProvider, getMaxEndOffset, getMode, getSingleFileMetadata, isSplittable, populateDisplayData, split, toString, validate

      • Methods inherited from class org.apache.beam.sdk.io.OffsetBasedSource

        getBytesPerOffset, getEndOffset, getMinBundleSize, getStartOffset

      • Methods inherited from class org.apache.beam.sdk.io.Source

        getDefaultOutputCoder

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    • Method Detail

      • createForSubrangeOfFile

        protected org.apache.beam.sdk.io.FileBasedSource<T> createForSubrangeOfFile​(org.apache.beam.sdk.io.fs.MatchResult.Metadata metadata,
                                                                            long start,
                                                                            long end)
        Specified by:
        createForSubrangeOfFile in class org.apache.beam.sdk.io.FileBasedSource<T>

      • createSingleFileReader

        protected org.apache.beam.sdk.io.FileBasedSource.FileBasedReader<T> createSingleFileReader​(org.apache.beam.sdk.options.PipelineOptions options)
        Specified by:
        createSingleFileReader in class org.apache.beam.sdk.io.FileBasedSource<T>

      • getOutputCoder

        public org.apache.beam.sdk.coders.Coder<T> getOutputCoder()
        Overrides:
        getOutputCoder in class org.apache.beam.sdk.io.Source<T>