diff --git a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java index 5491ca1dc..951d4cdd8 100644 --- a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java +++ b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java @@ -70,12 +70,16 @@ public enum SeaTunnelPluginMapping { SINK_S3_FILE(SEATUNNEL, SINK, S3_FILE, "connector-file-s3", GA, EXACTLY_ONCE), SOURCE_OSS_FILE(SEATUNNEL, SOURCE, OSS_FILE, "connector-file-oss", BETA, BATCH, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), SINK_OSS_FILE(SEATUNNEL, SINK, OSS_FILE, "connector-file-oss", BETA, EXACTLY_ONCE), - SOURCE_OSS_JINDO_FILE(SEATUNNEL, SOURCE, OSS_JINDO_FILE, "connector-file-oss-jindo", UNKNOWN, BATCH, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), - SINK_OSS_JINDO_FILE(SEATUNNEL, SINK, OSS_JINDO_FILE, "connector-file-oss-jindo", UNKNOWN, EXACTLY_ONCE), + SOURCE_OSS_JINDO_FILE(SEATUNNEL, SOURCE, OSS_JINDO_FILE, "connector-file-jindo-oss", UNKNOWN, BATCH, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), + SINK_OSS_JINDO_FILE(SEATUNNEL, SINK, OSS_JINDO_FILE, "connector-file-jindo-oss", UNKNOWN, EXACTLY_ONCE), + SOURCE_COS_FILE(SEATUNNEL, SOURCE, COS_FILE, "connector-file-cos", UNKNOWN, BATCH, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), + SINK_COS_FILE(SEATUNNEL, SINK, COS_FILE, "connector-file-cos", UNKNOWN, EXACTLY_ONCE), SOURCE_KAFKA(SEATUNNEL, SOURCE, KAFKA, "connector-kafka", GA, BATCH, STREAM, EXACTLY_ONCE, PARALLELISM), SINK_KAFKA(SEATUNNEL, SINK, KAFKA, "connector-kafka", GA, EXACTLY_ONCE), SOURCE_PULSAR(SEATUNNEL, SOURCE, PULSAR, "connector-pulsar", BETA, BATCH, STREAM, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), + SOURCE_ROCKETMQ(SEATUNNEL, SOURCE, ROCKETMQ, "connector-rocketmq", UNKNOWN, BATCH, STREAM, EXACTLY_ONCE, COLUMN_PROJECTION), + SINK_ROCKETMQ(SEATUNNEL, SINK, ROCKETMQ, "connector-rocketmq", UNKNOWN, EXACTLY_ONCE), SINK_DATAHUB(SEATUNNEL, SINK, DATAHUB, "connector-datahub", ALPHA), SOURCE_RABBITMQ(SEATUNNEL, SOURCE, RABBITMQ, "connector-rabbitmq", BETA, STREAM, EXACTLY_ONCE, COLUMN_PROJECTION), SINK_RABBITMQ(SEATUNNEL, SINK, RABBITMQ, "connector-rabbitmq", BETA), @@ -93,6 +97,7 @@ public enum SeaTunnelPluginMapping { SOURCE_CASSANDRA(SEATUNNEL, SOURCE, CASSANDRA, "connector-cassandra", BETA, BATCH, COLUMN_PROJECTION), SINK_CASSANDRA(SEATUNNEL, SINK, CASSANDRA, "connector-cassandra", BETA), SINK_TABLESTORE(SEATUNNEL, SINK, TABLESTORE, "connector-tablestore", ALPHA), + SINK_GOOGLE_FIRE_STORE(SEATUNNEL, SINK, GOOGLE_FIRE_STORE, "connector-google-firestore", UNKNOWN), SOURCE_MYSQL_CDC(SEATUNNEL, SOURCE, MYSQL_CDC, "connector-cdc-mysql", GA, STREAM, EXACTLY_ONCE, PARALLELISM, SUPPORT_USER_DEFINED_SPLIT), SOURCE_SQLSERVER_CDC(SEATUNNEL, SOURCE, SQLSERVER_CDC, "connector-cdc-sqlserver", GA, STREAM, EXACTLY_ONCE, PARALLELISM, SUPPORT_USER_DEFINED_SPLIT), @@ -109,6 +114,8 @@ public enum SeaTunnelPluginMapping { SINK_STARROCKS(SEATUNNEL, SINK, STARROCKS, "connector-starrocks", ALPHA), SOURCE_HUDI(SEATUNNEL, SOURCE, HUDI, "connector-hudi", BETA, BATCH, EXACTLY_ONCE, PARALLELISM), SOURCE_ICEBERG(SEATUNNEL, SOURCE, ICEBERG, "connector-iceberg", BETA, BATCH, STREAM, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), + SOURCE_PAIMON(SEATUNNEL, SOURCE, PAIMON, "connector-paimon", UNKNOWN, BATCH), + SINK_PAIMON(SEATUNNEL, SINK, PAIMON, "connector-paimon", UNKNOWN, EXACTLY_ONCE), SINK_S3REDSHIFT(SEATUNNEL, SINK, S3REDSHIFT, "connector-s3-redshift", GA, EXACTLY_ONCE), SOURCE_MAXCOMPUTE(SEATUNNEL, SOURCE, MAXCOMPUTE, "connector-maxcompute", ALPHA, BATCH, PARALLELISM), SINK_MAXCOMPUTE(SEATUNNEL, SINK, MAXCOMPUTE, "connector-maxcompute", ALPHA), diff --git a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginName.java b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginName.java index 401aef9ba..bab4710bd 100644 --- a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginName.java +++ b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginName.java @@ -55,9 +55,11 @@ public enum SeaTunnelPluginName implements DictInstance { S3_FILE("S3File", "S3File"), OSS_FILE("OssFile", "OssFile"), OSS_JINDO_FILE("OssJindoFile", "OssJindoFile"), + COS_FILE("CosFile", "CosFile"), KAFKA("Kafka", "Kafka"), PULSAR("Pulsar", "Pulsar"), + ROCKETMQ("Rocketmq", "RocketMQ"), DATAHUB("DataHub", "DataHub"), RABBITMQ("RabbitMQ", "RabbitMQ"), @@ -68,6 +70,7 @@ public enum SeaTunnelPluginName implements DictInstance { AMAZON_DYNAMODB("AmazonDynamodb", "AmazonDynamodb"), CASSANDRA("Cassandra", "Cassandra"), TABLESTORE("Tablestore", "Tablestore"), + GOOGLE_FIRE_STORE("GoogleFirestore", "GoogleFirestore"), MYSQL_CDC("MySQL-CDC", "MySQL-CDC"), SQLSERVER_CDC("SqlServer-CDC", "SqlServer-CDC"), @@ -81,6 +84,7 @@ public enum SeaTunnelPluginName implements DictInstance { STARROCKS("StarRocks", "StarRocks"), HUDI("Hudi", "Hudi"), ICEBERG("Iceberg", "Iceberg"), + PAIMON("Paimon", "Paimon"), S3REDSHIFT("S3Redshift", "S3Redshift"), MAXCOMPUTE("Maxcompute", "MaxCompute"), HBASE("Hbase", "Hbase"), diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/neo4j/Neo4jProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/neo4j/Neo4jProperties.java index 7b8d019be..af4bfa118 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/neo4j/Neo4jProperties.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/neo4j/Neo4jProperties.java @@ -88,6 +88,7 @@ public enum Neo4jProperties { .description("maximum transaction retry time(seconds). transaction fail if exceeded") .type(PropertyType.INT) .parser(Parsers.LONG_PARSER) + .defaultValue(30L) .addValidator(Validators.NON_NEGATIVE_INTEGER_VALIDATOR) .validateAndBuild(); @@ -96,6 +97,7 @@ public enum Neo4jProperties { .description("The maximum amount of time to wait for a TCP connection to be established (seconds)") .type(PropertyType.INT) .parser(Parsers.LONG_PARSER) + .defaultValue(30L) .addValidator(Validators.POSITIVE_INTEGER_VALIDATOR) .validateAndBuild(); diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/neo4j/source/Neo4jSourceProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/neo4j/source/Neo4jSourceProperties.java index 7d6bbf902..70ea577b2 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/neo4j/source/Neo4jSourceProperties.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/neo4j/source/Neo4jSourceProperties.java @@ -27,7 +27,7 @@ public enum Neo4jSourceProperties { public static final PropertyDescriptor SCHEMA = new PropertyDescriptor.Builder() .name("schema") .description("returned fields of query") - .type(PropertyType.STRING) + .type(PropertyType.OBJECT) .parser(Parsers.JSON_PARSER) .properties(Property.Required) .addValidator(Validators.NON_BLANK_VALIDATOR) diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourcePlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourcePlugin.java index f102c6158..40c0c4a7b 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourcePlugin.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourcePlugin.java @@ -59,6 +59,8 @@ public PulsarSourcePlugin() { props.add(CURSOR_RESET_MODE); props.add(CURSOR_STOP_MODE); props.add(CURSOR_STOP_TIMESTAMP); + props.add(FORMAT); + props.add(FIELD_DELIMITER); props.add(SCHEMA); props.add(CommonProperties.PARALLELISM); props.add(CommonProperties.RESULT_TABLE_NAME); diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourceProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourceProperties.java index fbbb5c340..1cbba8f37 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourceProperties.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourceProperties.java @@ -154,6 +154,24 @@ public enum PulsarSourceProperties { .addValidator(Validators.NON_BLANK_VALIDATOR) .validateAndBuild(); + public static final PropertyDescriptor FORMAT = new PropertyDescriptor.Builder() + .name("format") + .description("Data format.") + .type(PropertyType.STRING) + .parser(Parsers.STRING_PARSER) + .defaultValue("json") + .allowableValues("json", "text") + .addValidator(Validators.NON_BLANK_VALIDATOR) + .validateAndBuild(); + + public static final PropertyDescriptor FIELD_DELIMITER = new PropertyDescriptor.Builder() + .name("field_delimiter") + .description("The separator between columns in a row of data. Only needed by text and csv file format") + .type(PropertyType.STRING) + .parser(Parsers.STRING_PARSER) + .addValidator(Validators.NON_BLANK_VALIDATOR) + .validateAndBuild(); + public static final PropertyDescriptor SCHEMA = new PropertyDescriptor.Builder() .name("schema") .description("The schema information of upstream data.") diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/redis/sink/RedisSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/redis/sink/RedisSinkPlugin.java index 3f871b356..516f4c150 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/redis/sink/RedisSinkPlugin.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/redis/sink/RedisSinkPlugin.java @@ -51,6 +51,7 @@ public RedisSinkPlugin() { final List props = new ArrayList<>(); props.add(KEY); + props.add(EXPIRE); props.add(DATA_TYPE); props.add(FORMAT); props.add(CommonProperties.PARALLELISM); diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/redis/sink/RedisSinkProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/redis/sink/RedisSinkProperties.java index 0ef5364dc..87dbd2a32 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/redis/sink/RedisSinkProperties.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/redis/sink/RedisSinkProperties.java @@ -32,6 +32,15 @@ public enum RedisSinkProperties { .addValidator(Validators.NON_BLANK_VALIDATOR) .validateAndBuild(); + public static final PropertyDescriptor EXPIRE = new PropertyDescriptor.Builder() + .name("expire") + .description("Set redis expiration time.") + .type(PropertyType.INT) + .parser(Parsers.LONG_PARSER) + .defaultValue(-1L) + .addValidator(Validators.LONG_VALIDATOR) + .validateAndBuild(); + public static final PropertyDescriptor DATA_TYPE = new PropertyDescriptor.Builder() .name("data_type") .description("Redis data types") diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/socket/sink/SocketSinkProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/socket/sink/SocketSinkProperties.java index da9711056..932d0c421 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/socket/sink/SocketSinkProperties.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/socket/sink/SocketSinkProperties.java @@ -32,6 +32,6 @@ public enum SocketSinkProperties { .type(PropertyType.INT) .defaultValue(3) .parser(Parsers.INTEGER_PARSER) - .addValidator(Validators.NON_NEGATIVE_INTEGER_VALIDATOR) + .addValidator(Validators.POSITIVE_INTEGER_VALIDATOR) .validateAndBuild(); } diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/StarRocksProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/StarRocksProperties.java index 5bc95d5fc..fd366daf6 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/StarRocksProperties.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/StarRocksProperties.java @@ -26,7 +26,7 @@ public enum StarRocksProperties { ; public static final PropertyDescriptor> NODE_URLS = new PropertyDescriptor.Builder() - .name("node_urls") + .name("nodeUrls") .description("StarRocks cluster address") .type(PropertyType.STRING) .parser(Parsers.STRING_PARSER) diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/sink/StarRocksSinkProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/sink/StarRocksSinkProperties.java index 671ba08ad..03b453122 100644 --- a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/sink/StarRocksSinkProperties.java +++ b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/sink/StarRocksSinkProperties.java @@ -24,12 +24,12 @@ public enum StarRocksSinkProperties { ; - public static final PropertyDescriptor BASE_URL = new PropertyDescriptor.Builder<>() + public static final PropertyDescriptor BASE_URL = new PropertyDescriptor.Builder() .name("base-url") - .description("The JDBC URL like jdbc:mysql://localhost:9030/ or jdbc:mysql://localhost:9030 or jdbc:mysql://localhost:9030/db") - .properties(Property.Required) + .description("The JDBC URL") .type(PropertyType.STRING) .parser(Parsers.STRING_PARSER) + .properties(Property.Required) .addValidator(Validators.NON_BLANK_VALIDATOR) .validateAndBuild(); diff --git a/scaleph-ui-react/src/locales/zh-CN/pages/project.ts b/scaleph-ui-react/src/locales/zh-CN/pages/project.ts index 5226a73c2..0ba1cf66a 100644 --- a/scaleph-ui-react/src/locales/zh-CN/pages/project.ts +++ b/scaleph-ui-react/src/locales/zh-CN/pages/project.ts @@ -476,6 +476,7 @@ export default { 'pages.project.di.step.redis.hashKeyParseMode': 'Hash Key解析模式', 'pages.project.di.step.redis.format': '格式', 'pages.project.di.step.redis.key': '键', + 'pages.project.di.step.redis.expire': '过期时间（秒）', // pulsar 'pages.project.di.step.pulsar.clientServiceUrl': 'Client Service URL', @@ -498,6 +499,8 @@ export default { 'pages.project.di.step.pulsar.cursorStopMode': '游标停止模式', 'pages.project.di.step.pulsar.cursorStopMode.tooltip': '"Never"表示流，其他表示批', 'pages.project.di.step.pulsar.cursorStopTimestamp': '游标停止时间戳', + 'pages.project.di.step.pulsar.format': '数据格式', + 'pages.project.di.step.pulsar.fieldDelimiter': '分隔符', // datahub 'pages.project.di.step.datahub.endpoint': '终端节点', diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/constant.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/constant.tsx index 779b4fa63..4070275bb 100644 --- a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/constant.tsx +++ b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/constant.tsx @@ -418,7 +418,8 @@ export const RedisParams = { hashKeyParseMode: 'hash_key_parse_mode', format: 'format', schema: 'schema', - key: 'key' + key: 'key', + expire: 'expire' }; export const PulsarParams = { @@ -437,7 +438,9 @@ export const PulsarParams = { cursorStartupTimestamp: 'cursor.startup.timestamp', cursorResetMode: 'cursor.reset.mode', cursorStopMode: 'cursor.stop.mode', - cursorStopTimestamp: 'cursor.stop.timestamp' + cursorStopTimestamp: 'cursor.stop.timestamp', + format: 'format', + fieldDelimiter: 'field_delimiter' }; export const DatahubParams = { diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-redis-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-redis-step.tsx index 6a958b88e..75908e3b4 100644 --- a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-redis-step.tsx +++ b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-redis-step.tsx @@ -6,7 +6,7 @@ import {Button, Drawer, Form, message} from 'antd'; import {WsDiJob} from '@/services/project/typings'; import {getIntl, getLocale} from 'umi'; import {useEffect} from 'react'; -import {ProForm, ProFormSelect, ProFormText} from '@ant-design/pro-components'; +import {ProForm, ProFormDigit, ProFormSelect, ProFormText} from '@ant-design/pro-components'; import DataSourceItem from '@/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/dataSource'; const SinkRedisStepForm: React.FC< @@ -69,6 +69,14 @@ const SinkRedisStepForm: React.FC< label={intl.formatMessage({id: 'pages.project.di.step.redis.key'})} rules={[{required: true}]} /> + , }} /> - + + + {({format}) => { + if (format == 'json') { + return + } else if (format == 'text') { + return ( + + ); + } + return ; + }} + +