org.apache.hadoop.hive.serde2.io.TimestampWritable.writeToByteStream()方法的使用及代码示例

本文整理了Java中org.apache.hadoop.hive.serde2.io.TimestampWritable.writeToByteStream()方法的一些代码示例，展示了TimestampWritable.writeToByteStream()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TimestampWritable.writeToByteStream()方法的具体详情如下：
包路径：org.apache.hadoop.hive.serde2.io.TimestampWritable
类名称：TimestampWritable
方法名：writeToByteStream

TimestampWritable.writeToByteStream介绍

暂无

代码示例

代码示例来源：origin: org.spark-project.hive/hive-serde

@Override
public void writeTimestamp(Timestamp v) throws IOException {
// Every 8 fields we write a NULL byte.
if ((fieldIndex % 8) == 0) {
if (fieldIndex > 0) {
// Write back previous 8 field's NULL byte.
output.writeByte(nullOffset, nullByte);
nullByte = 0;
nullOffset = output.getLength();
}
// Allocate next NULL byte.
output.reserve(1);
}
// Set bit in NULL byte when a field is NOT NULL.
nullByte |= 1 <<(fieldIndex % 8);
if (timestampWritable == null) {
timestampWritable = new TimestampWritable();
}
timestampWritable.set(v);
timestampWritable.writeToByteStream(output);
fieldIndex++;
if (fieldIndex == fieldCount) {
// Write back the final NULL byte before the last fields.
output.writeByte(nullOffset, nullByte);
}
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

@Override
public void writeTimestamp(Timestamp v) throws IOException {
// Every 8 fields we write a NULL byte.
if ((fieldIndex % 8) == 0) {
if (fieldIndex > 0) {
// Write back previous 8 field's NULL byte.
output.writeByte(nullOffset, nullByte);
nullByte = 0;
nullOffset = output.getLength();
}
// Allocate next NULL byte.
output.reserve(1);
}
// Set bit in NULL byte when a field is NOT NULL.
nullByte |= 1 <<(fieldIndex % 8);
if (timestampWritable == null) {
timestampWritable = new TimestampWritable();
}
timestampWritable.set(v);
timestampWritable.writeToByteStream(output);
fieldIndex++;
if (fieldIndex == fieldCount) {
// Write back the final NULL byte before the last fields.
output.writeByte(nullOffset, nullByte);
}
}

代码示例来源：origin: com.github.hyukjinkwon/hive-serde

@Override
public void writeTimestamp(Timestamp v) throws IOException {
// Every 8 fields we write a NULL byte.
if ((fieldIndex % 8) == 0) {
if (fieldIndex > 0) {
// Write back previous 8 field's NULL byte.
output.writeByte(nullOffset, nullByte);
nullByte = 0;
nullOffset = output.getLength();
}
// Allocate next NULL byte.
output.reserve(1);
}
// Set bit in NULL byte when a field is NOT NULL.
nullByte |= 1 <<(fieldIndex % 8);
if (timestampWritable == null) {
timestampWritable = new TimestampWritable();
}
timestampWritable.set(v);
timestampWritable.writeToByteStream(output);
fieldIndex++;
if (fieldIndex == fieldCount) {
// Write back the final NULL byte before the last fields.
output.writeByte(nullOffset, nullByte);
}
}

代码示例来源：origin: com.github.hyukjinkwon/hive-serde

TimestampObjectInspector toi = (TimestampObjectInspector) poi;
TimestampWritable t = toi.getPrimitiveWritableObject(obj);
t.writeToByteStream(byteStream);
return;

代码示例来源：origin: org.spark-project.hive/hive-serde

TimestampObjectInspector toi = (TimestampObjectInspector) poi;
TimestampWritable t = toi.getPrimitiveWritableObject(obj);
t.writeToByteStream(byteStream);
return;

代码示例来源：origin: com.facebook.presto.hive/hive-apache

TimestampObjectInspector toi = (TimestampObjectInspector) poi;
TimestampWritable t = toi.getPrimitiveWritableObject(obj);
t.writeToByteStream(byteStream);
return;