From 91d225bcc401a108196ad5bad65ac1cd68ca44e5 Mon Sep 17 00:00:00 2001 From: Aitozi Date: Mon, 28 Oct 2024 13:38:27 +0800 Subject: [PATCH] format --- .../sink/partition/PartitionTrigger.java | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionTrigger.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionTrigger.java index 5a8b0753629d..4bb9097042fc 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionTrigger.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionTrigger.java @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package org.apache.paimon.flink.sink.partition; import org.apache.paimon.manifest.ManifestCommittable; @@ -5,6 +23,7 @@ import java.io.Closeable; import java.util.List; +/** The partition trigger. */ public interface PartitionTrigger extends Closeable { void notifyCommittable(List committables);