提交 d1fc3385 编写于 作者: G Gyula Fora 提交者: Stephan Ewen

[streaming] new streamrecord constructor added

上级 5547fc60
......@@ -38,6 +38,10 @@ public class StreamRecord implements IOReadableWritable, Serializable {
recordBatch.add(fields);
numOfRecords = recordBatch.size();
}
public StreamRecord(Value... values){
this(new AtomRecord(values));
}
public int getNumOfFields() {
return numOfFields;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册