This repository was archived by the owner on Nov 11, 2022. It is now read-only.
File tree Expand file tree Collapse file tree
sdk/src/main/java/com/google/cloud/dataflow/sdk/io Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -311,20 +311,20 @@ public PCollection<T> apply(PInput input) {
311311 switch (compressionType ) {
312312 case UNCOMPRESSED :
313313 read = com .google .cloud .dataflow .sdk .io .Read .from (
314- new TextSource <>(filepattern , coder ));
314+ new TextSource <T >(filepattern , coder ));
315315 break ;
316316 case AUTO :
317317 read = com .google .cloud .dataflow .sdk .io .Read .from (
318- CompressedSource .from (new TextSource <>(filepattern , coder )));
318+ CompressedSource .from (new TextSource <T >(filepattern , coder )));
319319 break ;
320320 case BZIP2 :
321321 read = com .google .cloud .dataflow .sdk .io .Read .from (
322- CompressedSource .from (new TextSource <>(filepattern , coder ))
322+ CompressedSource .from (new TextSource <T >(filepattern , coder ))
323323 .withDecompression (CompressedSource .CompressionMode .BZIP2 ));
324324 break ;
325325 case GZIP :
326326 read = com .google .cloud .dataflow .sdk .io .Read .from (
327- CompressedSource .from (new TextSource <>(filepattern , coder ))
327+ CompressedSource .from (new TextSource <T >(filepattern , coder ))
328328 .withDecompression (CompressedSource .CompressionMode .GZIP ));
329329 break ;
330330 default :
You can’t perform that action at this time.
0 commit comments