Put Transforms Implementation Details

PUT/transforms/{transforms_id}/implementation_details

Authorization

AuthorizationBearer token · headerrequired

Path parameters

transforms_idstringrequired

Request body

requiredapplication/json

transform_idstringrequired

version_idstring

default: ""

descriptionstring | any

Show properties

Any of:

string

string

any

any

configTransformConfig | TransformsEnrichAsyncConfig | any

Show properties

Any of:

TransformConfig

transforms.namestringrequired

transforms.languagestring | any

Show properties

Any of:

string

string

any

any

transforms.input.topic.patternstringrequired

transforms.output.topic.patternstringrequired

transforms.input.serialization.formatTransformSerializationFormatEnumrequired

Allowed:AnyJsonAvro

transforms.output.serialization.formatTransformSerializationFormatEnumrequired

Allowed:AnyJsonAvro

transforms.input.job.parallelisminteger

default: 5

transforms.topic.ttlstring | any

Show properties

Any of:

string

string

any

any

kc.cluster.idstring | any

Show properties

Any of:

string

string

any

any

TransformsEnrichAsyncConfig

transforms.namestringrequired

transforms.languagestring | any

Show properties

Any of:

string

string

any

any

transforms.input.topic.patternstringrequired

transforms.output.topic.patternstringrequired

transforms.input.serialization.formatTransformSerializationFormatEnumrequired

Allowed:AnyJsonAvro

transforms.output.serialization.formatTransformSerializationFormatEnumrequired

Allowed:AnyJsonAvro

transforms.input.job.parallelisminteger

default: 5

transforms.topic.ttlstring | any

Show properties

Any of:

string

string

any

any

kc.cluster.idstring | any

Show properties

Any of:

string

string

any

any

transforms.async.timeout.msinteger

default: 1000

transforms.async.capacityinteger

default: 10

any

any

created_timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

Show properties

Any of:

TransformsMapFilterImplementation

languageTransformLanguageEnumrequired

Allowed:PYTHONJAVASCRIPTSQL

value_transformstringrequired

key_transformstring | any

Show properties

Any of:

string

string

any

any

topic_transformstring | any

Show properties

Any of:

string

string

any

any

common_transformstring | any

Show properties

Any of:

string

string

any

any

value_schema_transformstring | any

Show properties

Any of:

string

string

any

any

key_schema_transformstring | any

Show properties

Any of:

string

string

any

any

unit_testTransformsUnitTest | any

Show properties

Any of:

TransformsUnitTest

test_namestringrequired

input__jsonTransformsImplementationDetailsTestRecord[]required

Show properties

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

output__jsonTransformsImplementationDetailsTestRecord[]required

Show properties

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

result__jsonTransformsImplementationDetailsTestRecord[] | any

Show properties

Any of:

TransformsImplementationDetailsTestRecord[]

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

any

any

is_successboolean | any

Show properties

Any of:

boolean

boolean

any

any

html_diffstring | any

Show properties

Any of:

string

string

any

any

text_diffstring | any

Show properties

Any of:

string

string

any

any

any

any

TransformsEnrichImplementation

mainTableTransformInputTablerequired

Show properties

namestringrequired

topicMatcherRegexstringrequired

createTableSQLstring | any

Show properties

Any of:

string

string

any

any

lookupTableTransformInputTablerequired

Show properties

namestringrequired

topicMatcherRegexstringrequired

createTableSQLstring | any

Show properties

Any of:

string

string

any

any

enrichSQLstringrequired

TransformsEnrichAsyncImplementation

languageTransformLanguageEnumrequired

Allowed:PYTHONJAVASCRIPTSQL

value_transformstringrequired

key_transformstring | any

Show properties

Any of:

string

string

any

any

topic_transformstring | any

Show properties

Any of:

string

string

any

any

common_transformstring | any

Show properties

Any of:

string

string

any

any

value_schema_transformstring | any

Show properties

Any of:

string

string

any

any

key_schema_transformstring | any

Show properties

Any of:

string

string

any

any

unit_testTransformsUnitTest | any

Show properties

Any of:

TransformsUnitTest

test_namestringrequired

input__jsonTransformsImplementationDetailsTestRecord[]required

Show properties

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

output__jsonTransformsImplementationDetailsTestRecord[]required

Show properties

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

result__jsonTransformsImplementationDetailsTestRecord[] | any

Show properties

Any of:

TransformsImplementationDetailsTestRecord[]

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

any

any

is_successboolean | any

Show properties

Any of:

boolean

boolean

any

any

html_diffstring | any

Show properties

Any of:

string

string

any

any

text_diffstring | any

Show properties

Any of:

string

string

any

any

any

any

async_timeout_msinteger

default: 2000

async_capacityinteger

default: 10

TransformsJoinImplementation

inputTablesTransformInputTable[]

Show properties

Array of TransformInputTable

namestringrequired

topicMatcherRegexstringrequired

createTableSQLstring | any

Show properties

Any of:

string

string

any

any

joinSQLstringrequired

keyFieldsstring[]

stateTtlMsstring | any

Show properties

Any of:

string

string

any

any

TransformsRollupImplementation

inputTablesTransformInputTable[]

Show properties

Array of TransformInputTable

namestringrequired

topicMatcherRegexstringrequired

createTableSQLstring | any

Show properties

Any of:

string

string

any

any

rollupSQLstringrequired

keyFieldsstring[]

sourceIdleTimeoutMsinteger

default: 30000

stateTTLMsinteger

default: 86400000

TransformsTopicRouterImplementation

topic_prefixstring

Deprecated - kept for backwards compat with existing DB records

default: ""

kc_cluster_idstring | any

KC cluster to deploy the connector to

Show properties

Any of:

string

string

any

any

any

any

Responses

200

Successful Response

transform_idstringrequired

version_idstring

default: ""

descriptionstring | any

Show properties

Any of:

string

string

any

any

configTransformConfig | TransformsEnrichAsyncConfig | any

Show properties

Any of:

TransformConfig

transforms.namestringrequired

transforms.languagestring | any

Show properties

Any of:

string

string

any

any

transforms.input.topic.patternstringrequired

transforms.output.topic.patternstringrequired

transforms.input.serialization.formatTransformSerializationFormatEnumrequired

Allowed:AnyJsonAvro

transforms.output.serialization.formatTransformSerializationFormatEnumrequired

Allowed:AnyJsonAvro

transforms.input.job.parallelisminteger

default: 5

transforms.topic.ttlstring | any

Show properties

Any of:

string

string

any

any

kc.cluster.idstring | any

Show properties

Any of:

string

string

any

any

TransformsEnrichAsyncConfig

transforms.namestringrequired

transforms.languagestring | any

Show properties

Any of:

string

string

any

any

transforms.input.topic.patternstringrequired

transforms.output.topic.patternstringrequired

transforms.input.serialization.formatTransformSerializationFormatEnumrequired

Allowed:AnyJsonAvro

transforms.output.serialization.formatTransformSerializationFormatEnumrequired

Allowed:AnyJsonAvro

transforms.input.job.parallelisminteger

default: 5

transforms.topic.ttlstring | any

Show properties

Any of:

string

string

any

any

kc.cluster.idstring | any

Show properties

Any of:

string

string

any

any

transforms.async.timeout.msinteger

default: 1000

transforms.async.capacityinteger

default: 10

any

any

created_timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

Show properties

Any of:

TransformsMapFilterImplementation

languageTransformLanguageEnumrequired

Allowed:PYTHONJAVASCRIPTSQL

value_transformstringrequired

key_transformstring | any

Show properties

Any of:

string

string

any

any

topic_transformstring | any

Show properties

Any of:

string

string

any

any

common_transformstring | any

Show properties

Any of:

string

string

any

any

value_schema_transformstring | any

Show properties

Any of:

string

string

any

any

key_schema_transformstring | any

Show properties

Any of:

string

string

any

any

unit_testTransformsUnitTest | any

Show properties

Any of:

TransformsUnitTest

test_namestringrequired

input__jsonTransformsImplementationDetailsTestRecord[]required

Show properties

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

output__jsonTransformsImplementationDetailsTestRecord[]required

Show properties

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

result__jsonTransformsImplementationDetailsTestRecord[] | any

Show properties

Any of:

TransformsImplementationDetailsTestRecord[]

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

any

any

is_successboolean | any

Show properties

Any of:

boolean

boolean

any

any

html_diffstring | any

Show properties

Any of:

string

string

any

any

text_diffstring | any

Show properties

Any of:

string

string

any

any

any

any

TransformsEnrichImplementation

mainTableTransformInputTablerequired

Show properties

namestringrequired

topicMatcherRegexstringrequired

createTableSQLstring | any

Show properties

Any of:

string

string

any

any

lookupTableTransformInputTablerequired

Show properties

namestringrequired

topicMatcherRegexstringrequired

createTableSQLstring | any

Show properties

Any of:

string

string

any

any

enrichSQLstringrequired

TransformsEnrichAsyncImplementation

languageTransformLanguageEnumrequired

Allowed:PYTHONJAVASCRIPTSQL

value_transformstringrequired

key_transformstring | any

Show properties

Any of:

string

string

any

any

topic_transformstring | any

Show properties

Any of:

string

string

any

any

common_transformstring | any

Show properties

Any of:

string

string

any

any

value_schema_transformstring | any

Show properties

Any of:

string

string

any

any

key_schema_transformstring | any

Show properties

Any of:

string

string

any

any

unit_testTransformsUnitTest | any

Show properties

Any of:

TransformsUnitTest

test_namestringrequired

input__jsonTransformsImplementationDetailsTestRecord[]required

Show properties

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

output__jsonTransformsImplementationDetailsTestRecord[]required

Show properties

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

result__jsonTransformsImplementationDetailsTestRecord[] | any

Show properties

Any of:

TransformsImplementationDetailsTestRecord[]

Array of TransformsImplementationDetailsTestRecord

topicstringrequired

valueobjectrequired

keyobject | any

Show properties

Any of:

object

object

any

any

timestampstring<date-time> | any

Show properties

Any of:

string<date-time>

string<date-time>

any

any

any

any

is_successboolean | any

Show properties

Any of:

boolean

boolean

any

any

html_diffstring | any

Show properties

Any of:

string

string

any

any

text_diffstring | any

Show properties

Any of:

string

string

any

any

any

any

async_timeout_msinteger

default: 2000

async_capacityinteger

default: 10

TransformsJoinImplementation

inputTablesTransformInputTable[]

Show properties

Array of TransformInputTable

namestringrequired

topicMatcherRegexstringrequired

createTableSQLstring | any

Show properties

Any of:

string

string

any

any

joinSQLstringrequired

keyFieldsstring[]

stateTtlMsstring | any

Show properties

Any of:

string

string

any

any

TransformsRollupImplementation

inputTablesTransformInputTable[]

Show properties

Array of TransformInputTable

namestringrequired

topicMatcherRegexstringrequired

createTableSQLstring | any

Show properties

Any of:

string

string

any

any

rollupSQLstringrequired

keyFieldsstring[]

sourceIdleTimeoutMsinteger

default: 30000

stateTTLMsinteger

default: 86400000

TransformsTopicRouterImplementation

topic_prefixstring

Deprecated - kept for backwards compat with existing DB records

default: ""

kc_cluster_idstring | any

KC cluster to deploy the connector to

Show properties

Any of:

string

string

any

any

any

any

422

Validation Error

detailValidationError[]

Show properties

Array of ValidationError

locstring | integer[]required

Show properties

Array of string | integer

Any of:

string

string

integer

integer

msgstringrequired

typestringrequired

inputany

ctxobject

Request

curl -X PUT "https://api.streamkap.com/transforms/string/implementation_details" \
  -H "Authorization: Bearer YOUR_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
  "transform_id": "string",
  "version_id": "",
  "description": "string",
  "config": {
    "transforms.name": "string",
    "transforms.language": "string",
    "transforms.input.topic.pattern": "string",
    "transforms.output.topic.pattern": "string",
    "transforms.input.serialization.format": "Any",
    "transforms.output.serialization.format": "Any",
    "transforms.input.job.parallelism": 5,
    "transforms.topic.ttl": "string",
    "kc.cluster.id": "string"
  },
  "created_timestamp": "2019-08-24T14:15:22Z",
  "implementation": {
    "language": "PYTHON",
    "value_transform": "string",
    "key_transform": "string",
    "topic_transform": "string",
    "common_transform": "string",
    "value_schema_transform": "string",
    "key_schema_transform": "string",
    "unit_test": {
      "test_name": "string",
      "input__json": [
        {
          "topic": "string",
          "value": {},
          "key": {},
          "timestamp": "2019-08-24T14:15:22Z"
        }
      ],
      "output__json": [
        {
          "topic": "string",
          "value": {},
          "key": {},
          "timestamp": "2019-08-24T14:15:22Z"
        }
      ],
      "result__json": [
        {
          "topic": "string",
          "value": {},
          "key": {},
          "timestamp": "2019-08-24T14:15:22Z"
        }
      ],
      "is_success": true,
      "html_diff": "string",
      "text_diff": "string"
    }
  }
}'

const response = await fetch("https://api.streamkap.com/transforms/string/implementation_details", {
  method: "PUT",
  headers: {
    "Authorization": "Bearer YOUR_TOKEN",
    "Content-Type": "application/json"
  },
  body: "{\n  \"transform_id\": \"string\",\n  \"version_id\": \"\",\n  \"description\": \"string\",\n  \"config\": {\n    \"transforms.name\": \"string\",\n    \"transforms.language\": \"string\",\n    \"transforms.input.topic.pattern\": \"string\",\n    \"transforms.output.topic.pattern\": \"string\",\n    \"transforms.input.serialization.format\": \"Any\",\n    \"transforms.output.serialization.format\": \"Any\",\n    \"transforms.input.job.parallelism\": 5,\n    \"transforms.topic.ttl\": \"string\",\n    \"kc.cluster.id\": \"string\"\n  },\n  \"created_timestamp\": \"2019-08-24T14:15:22Z\",\n  \"implementation\": {\n    \"language\": \"PYTHON\",\n    \"value_transform\": \"string\",\n    \"key_transform\": \"string\",\n    \"topic_transform\": \"string\",\n    \"common_transform\": \"string\",\n    \"value_schema_transform\": \"string\",\n    \"key_schema_transform\": \"string\",\n    \"unit_test\": {\n      \"test_name\": \"string\",\n      \"input__json\": [\n        {\n          \"topic\": \"string\",\n          \"value\": {},\n          \"key\": {},\n          \"timestamp\": \"2019-08-24T14:15:22Z\"\n        }\n      ],\n      \"output__json\": [\n        {\n          \"topic\": \"string\",\n          \"value\": {},\n          \"key\": {},\n          \"timestamp\": \"2019-08-24T14:15:22Z\"\n        }\n      ],\n      \"result__json\": [\n        {\n          \"topic\": \"string\",\n          \"value\": {},\n          \"key\": {},\n          \"timestamp\": \"2019-08-24T14:15:22Z\"\n        }\n      ],\n      \"is_success\": true,\n      \"html_diff\": \"string\",\n      \"text_diff\": \"string\"\n    }\n  }\n}"
});

import requests

response = requests.put(
    "https://api.streamkap.com/transforms/string/implementation_details",
    headers={
        "Authorization": "Bearer YOUR_TOKEN",
        "Content-Type": "application/json"
    },
    data="{\n  \"transform_id\": \"string\",\n  \"version_id\": \"\",\n  \"description\": \"string\",\n  \"config\": {\n    \"transforms.name\": \"string\",\n    \"transforms.language\": \"string\",\n    \"transforms.input.topic.pattern\": \"string\",\n    \"transforms.output.topic.pattern\": \"string\",\n    \"transforms.input.serialization.format\": \"Any\",\n    \"transforms.output.serialization.format\": \"Any\",\n    \"transforms.input.job.parallelism\": 5,\n    \"transforms.topic.ttl\": \"string\",\n    \"kc.cluster.id\": \"string\"\n  },\n  \"created_timestamp\": \"2019-08-24T14:15:22Z\",\n  \"implementation\": {\n    \"language\": \"PYTHON\",\n    \"value_transform\": \"string\",\n    \"key_transform\": \"string\",\n    \"topic_transform\": \"string\",\n    \"common_transform\": \"string\",\n    \"value_schema_transform\": \"string\",\n    \"key_schema_transform\": \"string\",\n    \"unit_test\": {\n      \"test_name\": \"string\",\n      \"input__json\": [\n        {\n          \"topic\": \"string\",\n          \"value\": {},\n          \"key\": {},\n          \"timestamp\": \"2019-08-24T14:15:22Z\"\n        }\n      ],\n      \"output__json\": [\n        {\n          \"topic\": \"string\",\n          \"value\": {},\n          \"key\": {},\n          \"timestamp\": \"2019-08-24T14:15:22Z\"\n        }\n      ],\n      \"result__json\": [\n        {\n          \"topic\": \"string\",\n          \"value\": {},\n          \"key\": {},\n          \"timestamp\": \"2019-08-24T14:15:22Z\"\n        }\n      ],\n      \"is_success\": true,\n      \"html_diff\": \"string\",\n      \"text_diff\": \"string\"\n    }\n  }\n}",
)

Response

{
  "transform_id": "string",
  "version_id": "",
  "description": "string",
  "config": {
    "transforms.name": "string",
    "transforms.language": "string",
    "transforms.input.topic.pattern": "string",
    "transforms.output.topic.pattern": "string",
    "transforms.input.serialization.format": "Any",
    "transforms.output.serialization.format": "Any",
    "transforms.input.job.parallelism": 5,
    "transforms.topic.ttl": "string",
    "kc.cluster.id": "string"
  },
  "created_timestamp": "2019-08-24T14:15:22Z",
  "implementation": {
    "language": "PYTHON",
    "value_transform": "string",
    "key_transform": "string",
    "topic_transform": "string",
    "common_transform": "string",
    "value_schema_transform": "string",
    "key_schema_transform": "string",
    "unit_test": {
      "test_name": "string",
      "input__json": [
        {
          "topic": "string",
          "value": {},
          "key": {},
          "timestamp": "2019-08-24T14:15:22Z"
        }
      ],
      "output__json": [
        {
          "topic": "string",
          "value": {},
          "key": {},
          "timestamp": "2019-08-24T14:15:22Z"
        }
      ],
      "result__json": [
        {
          "topic": "string",
          "value": {},
          "key": {},
          "timestamp": "2019-08-24T14:15:22Z"
        }
      ],
      "is_success": true,
      "html_diff": "string",
      "text_diff": "string"
    }
  }
}

{
  "detail": [
    {
      "loc": [
        "string"
      ],
      "msg": "string",
      "type": "string",
      "input": null,
      "ctx": {}
    }
  ]
}