方法1：
LogicalType[] orcTypes = new LogicalType[]{new VarCharType(255),new VarCharType(255),new IntType()};
String[] fields = new String[]{"name","gread","cource"};
TypeDescription typeDescription = OrcSplitReaderUtil.logicalTypeToOrcType(RowType.of(
orcTypes,
fields));
//写入orc格式的属性
final Properties writerProps = new Properties();
writerProps.setProperty("orc.compress", "LZ4");
//构造工厂类OrcBulkWriterFactory
final OrcBulkWriterFactory factory = new OrcBulkWriterFactory<>(
new FieldsVectorizer(typeDescription.toString()),
writerProps,
new Configuration());
final StreamingFileSink sink = StreamingFileSink
.forBulkFormat(new Path(hdfsPath),factory)
.withNewBucketAssigner(new LogBucketAssigner())
.build();
.......
datastream. 
