TFRecordIO { public static Read read() { return new AutoValue_TFRecordIO_Read.Builder() .setValidate(true) .setCompression(Compression.AUTO) .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 testReadNamed() { readPipeline.enableAbandonedNodeEnforcement(false); assertThat( readPipeline.apply(TFRecordIO.read().from("foo.*").withoutValidation()).getName(), startsWith("TFRecordIO.Read/Read")); assertThat( readPipeline.apply("MyRead", TFRecordIO.read().from("foo.*").withoutValidation()).getName(), startsWith("MyRead/Read")); }
@Test public void testReadDisplayData() { TFRecordIO.Read read = TFRecordIO.read().from("foo.*").withCompression(GZIP).withoutValidation(); DisplayData displayData = DisplayData.from(read); assertThat(displayData, hasDisplayItem("filePattern", "foo.*")); assertThat(displayData, hasDisplayItem("compressionType", GZIP.toString())); assertThat(displayData, hasDisplayItem("validation", false)); }
@Test public void testReadNamed() { readPipeline.enableAbandonedNodeEnforcement(false); assertEquals( "TFRecordIO.Read/Read.out", readPipeline.apply(TFRecordIO.read().from("foo.*").withoutValidation()).getName()); assertEquals( "MyRead/Read.out", readPipeline .apply("MyRead", TFRecordIO.read().from("foo.*").withoutValidation()) .getName()); }