fork download
copy 
  1. import org.apache.flink.core.io.SimpleVersionedSerializer;
  2. import org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner;
  3. import org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.SimpleVersionedStringSerializer;
  4.  
  5. public class FileBucketAssigner implements BucketAssigner<InputRecordPojo, String> {
  6.  
  7.   @Override
  8.   public String getBucketId(InputRecordPojo record, Context context) {
  9. 	return extractCustomerID(record);
  10.   }
  11.  
  12.   @Override
  13.   public SimpleVersionedSerializer<String> getSerializer() {
  14.     return SimpleVersionedStringSerializer.INSTANCE;
  15.   }
  16. }
  17.  
  18. FileSink<InputRecordPojo> sink =
  19.         FileSink.forRowFormat(...)
  20.             .withBucketAssigner(new FileBucketAssigner())
  21.             .build();
Compilation error #stdin compilation error #stdout 0s 0KB
comments (?)
stdin
copy 
Standard input is empty
compilation info 
Main.java:18: error: class, interface, or enum expected
FileSink<InputRecordPojo> sink =
^
1 error
stdout
copy 
Standard output is empty
https://ideone.com/Yu3Zse
language:
Java (HotSpot 12)
created:
2 years ago
visibility:
secret

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!