private static long getRecordTimestamp ( Optional < Object > writerPartitionColumnValue ) { return writerPartitionColumnValue . orNull ( ) instanceof Long ? ( Long ) writerPartitionColumnValue . get ( ) : System . currentTimeMillis ( ) ; }
Check if the partition column value is present and is a Long object . Otherwise use current system time .