TFRecordIO { public static ReadFiles readFiles() { return new AutoValue_TFRecordIO_ReadFiles.Builder().build(); } private  TFRecordIO(); static Read read(); static ReadFiles readFiles(); static Write write(); static Sink sink(); static final Coder<byte[]> DEFAULT_BYTE_ARRAY_CODER; }
@Test public void testReadFilesNamed() { readPipeline.enableAbandonedNodeEnforcement(false); Metadata metadata = Metadata.builder() .setResourceId(FileSystems.matchNewResource("file", false )) .setIsReadSeekEfficient(true) .setSizeBytes(1024) .build(); Create.Values<ReadableFile> create = Create.of(new ReadableFile(metadata, Compression.AUTO)); assertEquals( "TFRecordIO.ReadFiles/Read all via FileBasedSource/Read ranges/ParMultiDo(ReadFileRanges).output", readPipeline.apply(create).apply(TFRecordIO.readFiles()).getName()); assertEquals( "MyRead/Read all via FileBasedSource/Read ranges/ParMultiDo(ReadFileRanges).output", readPipeline.apply(create).apply("MyRead", TFRecordIO.readFiles()).getName()); }