Modifier and Type | Method and Description |
---|---|
Timestamp |
PartitionSettedRow.getTimestamp(int pos,
int precision) |
Modifier and Type | Method and Description |
---|---|
static long |
ArrowUtils.timestampToEpoch(Timestamp timestamp,
int precision,
java.time.ZoneId castZoneId) |
Modifier and Type | Method and Description |
---|---|
Timestamp |
CastedRow.getTimestamp(int pos,
int precision) |
Timestamp |
DefaultValueRow.getTimestamp(int pos,
int precision) |
Modifier and Type | Method and Description |
---|---|
CastExecutor<Timestamp,Number> |
TimestampToNumericPrimitiveCastRule.create(DataType inputType,
DataType targetType) |
CastExecutor<Number,Timestamp> |
NumericPrimitiveToTimestamp.create(DataType inputType,
DataType targetType) |
Modifier and Type | Method and Description |
---|---|
static Timestamp |
Timestamp.fromEpochMillis(long milliseconds)
Creates an instance of
Timestamp from milliseconds. |
static Timestamp |
Timestamp.fromEpochMillis(long milliseconds,
int nanosOfMillisecond)
Creates an instance of
Timestamp from milliseconds and a nanos-of-millisecond. |
static Timestamp |
Timestamp.fromInstant(java.time.Instant instant)
Deprecated.
use
LocalZoneTimestamp . |
static Timestamp |
Timestamp.fromLocalDateTime(java.time.LocalDateTime dateTime)
Creates an instance of
Timestamp from an instance of LocalDateTime . |
static Timestamp |
Timestamp.fromMicros(long micros)
Creates an instance of
Timestamp from micros. |
static Timestamp |
Timestamp.fromSQLTimestamp(Timestamp timestamp)
|
Timestamp |
LazyGenericRow.getTimestamp(int pos,
int precision) |
Timestamp |
NestedRow.getTimestamp(int pos,
int precision) |
Timestamp |
BinaryArray.getTimestamp(int pos,
int precision) |
Timestamp |
GenericArray.getTimestamp(int pos,
int precision) |
Timestamp |
GenericRow.getTimestamp(int pos,
int precision) |
Timestamp |
DataGetters.getTimestamp(int pos,
int precision)
Returns the timestamp value at the given position.
|
Timestamp |
JoinedRow.getTimestamp(int pos,
int precision) |
Timestamp |
BinaryRow.getTimestamp(int pos,
int precision) |
static Timestamp |
Timestamp.now()
Creates an instance of
Timestamp for now. |
Timestamp |
Timestamp.toMillisTimestamp() |
Modifier and Type | Method and Description |
---|---|
int |
Timestamp.compareTo(Timestamp that) |
void |
NestedRow.setTimestamp(int pos,
Timestamp value,
int precision) |
void |
BinaryArray.setTimestamp(int pos,
Timestamp value,
int precision) |
void |
DataSetters.setTimestamp(int pos,
Timestamp value,
int precision)
Set Timestamp value.
|
void |
BinaryRow.setTimestamp(int pos,
Timestamp value,
int precision) |
void |
BinaryWriter.writeTimestamp(int pos,
Timestamp value,
int precision) |
Modifier and Type | Method and Description |
---|---|
Timestamp |
Dictionary.decodeToTimestamp(int id) |
Timestamp |
ColumnarArray.getTimestamp(int pos,
int precision) |
Timestamp |
ColumnarRow.getTimestamp(int pos,
int precision) |
Timestamp |
TimestampColumnVector.getTimestamp(int i,
int precision) |
Timestamp |
VectorizedColumnBatch.getTimestamp(int rowId,
int colId,
int precision) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnarArray.setTimestamp(int pos,
Timestamp value,
int precision) |
void |
ColumnarRow.setTimestamp(int pos,
Timestamp value,
int precision) |
Modifier and Type | Method and Description |
---|---|
Timestamp |
HeapTimestampVector.getTimestamp(int i,
int precision) |
Modifier and Type | Method and Description |
---|---|
void |
HeapTimestampVector.fill(Timestamp value) |
void |
HeapTimestampVector.setTimestamp(int i,
Timestamp timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
WritableTimestampVector.fill(Timestamp value)
Fill the column vector with the provided value.
|
void |
WritableTimestampVector.setTimestamp(int rowId,
Timestamp timestamp)
Set
Timestamp at rowId with the provided value. |
Modifier and Type | Method and Description |
---|---|
Timestamp |
SafeBinaryRow.getTimestamp(int pos,
int precision) |
Timestamp |
SafeBinaryArray.getTimestamp(int pos,
int precision) |
Modifier and Type | Method and Description |
---|---|
Timestamp |
TimestampSerializer.copy(Timestamp from) |
Timestamp |
TimestampSerializer.deserialize(DataInputView source) |
Timestamp |
TimestampSerializer.deserializeFromString(String s) |
Modifier and Type | Method and Description |
---|---|
Serializer<Timestamp> |
TimestampSerializer.duplicate() |
Modifier and Type | Method and Description |
---|---|
Timestamp |
TimestampSerializer.copy(Timestamp from) |
void |
TimestampSerializer.serialize(Timestamp record,
DataOutputView target) |
String |
TimestampSerializer.serializeToString(Timestamp record) |
Modifier and Type | Method and Description |
---|---|
static Timestamp |
FlinkRowWrapper.fromFlinkTimestamp(org.apache.flink.table.data.TimestampData timestamp) |
Timestamp |
FlinkRowWrapper.getTimestamp(int pos,
int precision) |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.table.data.TimestampData |
FlinkRowData.toFlinkTimestamp(Timestamp timestamp) |
Modifier and Type | Method and Description |
---|---|
Timestamp |
OrcTimestampColumnVector.getTimestamp(int i,
int precision) |
Timestamp |
OrcLegacyTimestampColumnVector.getTimestamp(int i,
int precision) |
Modifier and Type | Method and Description |
---|---|
static Timestamp |
TimestampColumnReader.decodeInt96ToTimestamp(boolean utcTimestamp,
org.apache.parquet.column.Dictionary dictionary,
int id) |
Timestamp |
ParquetDictionary.decodeToTimestamp(int id) |
Timestamp |
ParquetTimestampVector.getTimestamp(int i,
int precision) |
static Timestamp |
TimestampColumnReader.int96ToTimestamp(boolean utcTimestamp,
long nanosOfDay,
int julianDay) |
Timestamp |
ParquetDataColumnReader.readMicrosTimestamp() |
Timestamp |
ParquetDataColumnReader.readMicrosTimestamp(int id) |
Timestamp |
ParquetDataColumnReader.readMillsTimestamp() |
Timestamp |
ParquetDataColumnReader.readMillsTimestamp(int id) |
Timestamp |
ParquetDataColumnReader.readNanosTimestamp() |
Timestamp |
ParquetDataColumnReader.readNanosTimestamp(int id) |
Modifier and Type | Method and Description |
---|---|
Timestamp |
PaimonTimestampObjectInspector.convert(Object value) |
Timestamp |
HivePaimonArray.getTimestamp(int i,
int precision) |
Modifier and Type | Method and Description |
---|---|
Timestamp |
DataFileMeta.creationTime() |
Constructor and Description |
---|
DataFileMeta(String fileName,
long fileSize,
long rowCount,
BinaryRow minKey,
BinaryRow maxKey,
SimpleStats keyStats,
SimpleStats valueStats,
long minSequenceNumber,
long maxSequenceNumber,
long schemaId,
int level,
List<String> extraFiles,
Timestamp creationTime,
Long deleteRowCount,
byte[] embeddedIndex,
FileSource fileSource) |
Modifier and Type | Method and Description |
---|---|
Timestamp |
TableLineageEntityImpl.getCreateTime() |
Timestamp |
TableLineageEntity.getCreateTime() |
Timestamp |
DataLineageEntity.getCreateTime() |
Constructor and Description |
---|
TableLineageEntityImpl(String database,
String table,
String job,
Timestamp timestamp) |
Modifier and Type | Method and Description |
---|---|
static Timestamp |
MemorySegmentUtils.readTimestampData(MemorySegment[] segments,
int baseOffset,
long offsetAndNanos)
Gets an instance of
Timestamp from underlying MemorySegment . |
Modifier and Type | Method and Description |
---|---|
Timestamp |
SparkRow.getTimestamp(int i,
int precision) |
Modifier and Type | Method and Description |
---|---|
static long |
SparkInternalRow.fromPaimon(Timestamp timestamp) |
Modifier and Type | Method and Description |
---|---|
static Timestamp |
DateTimeUtils.dateToTimestampWithLocalZone(int date,
TimeZone tz) |
Timestamp |
PartialRow.getTimestamp(int pos,
int precision) |
Timestamp |
OffsetRow.getTimestamp(int pos,
int precision) |
Timestamp |
KeyProjectedRow.getTimestamp(int pos,
int precision) |
Timestamp |
ProjectedRow.getTimestamp(int pos,
int precision) |
static Timestamp |
DateTimeUtils.parseTimestampData(String dateStr,
int precision) |
static Timestamp |
DateTimeUtils.parseTimestampData(String dateStr,
int precision,
TimeZone timeZone) |
static Timestamp |
DateTimeUtils.timestampToTimestampWithLocalZone(Timestamp ts,
TimeZone tz) |
static Timestamp |
DateTimeUtils.timestampWithLocalZoneToTimestamp(Timestamp ts,
TimeZone tz) |
static Timestamp |
DateTimeUtils.timeToTimestampWithLocalZone(int time,
TimeZone tz) |
static Timestamp |
DateTimeUtils.toInternal(long millis,
int nanos) |
static Timestamp |
BinaryStringUtils.toTimestamp(BinaryString input,
int precision)
Used by
CAST(x as TIMESTAMP) . |
static Timestamp |
BinaryStringUtils.toTimestamp(BinaryString input,
int precision,
TimeZone timeZone)
Used by
CAST(x as TIMESTAMP_LTZ) . |
static Timestamp |
DateTimeUtils.truncate(Timestamp ts,
int precision) |
Modifier and Type | Method and Description |
---|---|
static String |
DateTimeUtils.formatTimestamp(Timestamp ts,
int precision) |
static String |
DateTimeUtils.formatTimestamp(Timestamp ts,
TimeZone tz,
int precision) |
static void |
SortUtil.putTimestampNormalizedKey(Timestamp value,
MemorySegment target,
int offset,
int numBytes)
Support the compact precision TimestampData.
|
static Timestamp |
DateTimeUtils.timestampToTimestampWithLocalZone(Timestamp ts,
TimeZone tz) |
static int |
DateTimeUtils.timestampWithLocalZoneToDate(Timestamp ts,
TimeZone tz) |
static int |
DateTimeUtils.timestampWithLocalZoneToTime(Timestamp ts,
TimeZone tz) |
static Timestamp |
DateTimeUtils.timestampWithLocalZoneToTimestamp(Timestamp ts,
TimeZone tz) |
static Timestamp |
DateTimeUtils.truncate(Timestamp ts,
int precision) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.