diff --git a/src/v/datalake/BUILD b/src/v/datalake/BUILD index 5e717d0b657f..fed4bd5f4b5c 100644 --- a/src/v/datalake/BUILD +++ b/src/v/datalake/BUILD @@ -148,7 +148,6 @@ redpanda_cc_library( ], hdrs = [ "data_writer_interface.h", - "schemaless_translator.h", ], implementation_deps = [ "@fmt", @@ -157,12 +156,9 @@ redpanda_cc_library( visibility = [":__subpackages__"], deps = [ ":base_types", - ":table_definition", "//src/v/base", - "//src/v/datalake/coordinator:data_file", "//src/v/iceberg:datatypes", "//src/v/iceberg:values", - "//src/v/serde", ], ) diff --git a/src/v/datalake/CMakeLists.txt b/src/v/datalake/CMakeLists.txt index ea5b89be7180..c59c9e0043e3 100644 --- a/src/v/datalake/CMakeLists.txt +++ b/src/v/datalake/CMakeLists.txt @@ -39,7 +39,6 @@ v_cc_library( record_schema_resolver.cc record_translator.cc schema_registry.cc - schemaless_translator.cc schema_avro.cc schema_protobuf.cc partitioning_writer.cc diff --git a/src/v/datalake/schemaless_translator.cc b/src/v/datalake/schemaless_translator.cc deleted file mode 100644 index 6facaf42ad1f..000000000000 --- a/src/v/datalake/schemaless_translator.cc +++ /dev/null @@ -1,33 +0,0 @@ -/* - * Copyright 2024 Redpanda Data, Inc. - * - * Licensed as a Redpanda Enterprise file under the Redpanda Community - * License (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * https://github.com/redpanda-data/redpanda/blob/master/licenses/rcl.md - */ - -#include "datalake/schemaless_translator.h" - -#include "datalake/table_definition.h" -#include "iceberg/values.h" - -namespace datalake { - -iceberg::struct_value schemaless_translator::translate_event( - iobuf key, iobuf value, int64_t timestamp, int64_t offset) const { - using namespace iceberg; - struct_value res; - res.fields.emplace_back(long_value(offset)); - res.fields.emplace_back(timestamp_value(timestamp)); - res.fields.emplace_back(binary_value(std::move(key))); - res.fields.emplace_back(binary_value(std::move(value))); - return res; -} - -iceberg::struct_type schemaless_translator::get_schema() const { - return schemaless_struct_type(); -} - -} // namespace datalake diff --git a/src/v/datalake/schemaless_translator.h b/src/v/datalake/schemaless_translator.h deleted file mode 100644 index b2c80d734810..000000000000 --- a/src/v/datalake/schemaless_translator.h +++ /dev/null @@ -1,27 +0,0 @@ -/* - * Copyright 2024 Redpanda Data, Inc. - * - * Licensed as a Redpanda Enterprise file under the Redpanda Community - * License (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * https://github.com/redpanda-data/redpanda/blob/master/licenses/rcl.md - */ -#pragma once - -#include "bytes/iobuf.h" -#include "iceberg/datatypes.h" -#include "iceberg/values.h" - -#include -#include - -namespace datalake { -class schemaless_translator { -public: - iceberg::struct_value translate_event( - iobuf key, iobuf value, int64_t timestamp, int64_t offset) const; - - iceberg::struct_type get_schema() const; -}; -} // namespace datalake