From de398c5ed697b7cc0040e2b53769b6f0211bc335 Mon Sep 17 00:00:00 2001 From: Stefan Bocutiu Date: Tue, 12 Mar 2024 15:34:19 +0000 Subject: [PATCH] Update InsertRecordTimestampHeaders.md Fix the SMT class name --- InsertRecordTimestampHeaders.md | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/InsertRecordTimestampHeaders.md b/InsertRecordTimestampHeaders.md index cfa995d..eaea4b4 100644 --- a/InsertRecordTimestampHeaders.md +++ b/InsertRecordTimestampHeaders.md @@ -57,14 +57,14 @@ To store the epoch value, use the following configuration: ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders ``` To prefix the headers with `wallclock_`, use the following: ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders transforms.InsertWallclock.header.prefix.name=wallclock_ ``` @@ -72,7 +72,7 @@ To change the date format, use the following: ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders transforms.InsertWallclock.date.format=yyyy-MM-dd ``` @@ -80,7 +80,7 @@ To use the timezone `Asia/Kolkoata`, use the following: ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders transforms.InsertWallclock.timezone=Asia/Kolkata ``` @@ -89,7 +89,7 @@ as `date=yyyy-MM-dd / hour=HH`, employ the following SMT configuration for a par ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders transforms.InsertWallclock.date.format="date=yyyy-MM-dd" transforms.InsertWallclock.hour.format="hour=yyyy" ``` @@ -98,4 +98,4 @@ and in the KCQL setting utilise the headers as partitioning keys: ```properties connect.s3.kcql=INSERT INTO $bucket:prefix SELECT * FROM kafka_topic PARTITIONBY _header.date, _header.year -``` \ No newline at end of file +```