Skip to content

Commit

Permalink
Fix javadoc errors
Browse files Browse the repository at this point in the history
Signed-off-by: Rishabh Maurya <rishabhmaurya05@gmail.com>
  • Loading branch information
rishabhmaurya committed Feb 11, 2025
1 parent 14bb126 commit cf1733f
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -169,7 +169,7 @@ boolean isStale() {
* @param nodeId The ID of the node this holder belongs to
* @param reason The reason for closing
*/
public void close(String nodeId, String reason) {
void close(String nodeId, String reason) {
try {
if (flightClient != null) {
flightClient.close();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,8 +52,8 @@ public class FlightStreamManager implements StreamManager {
/**
* Holds a StreamProducer along with its metadata and resources
*/
public record StreamProducerHolder(StreamProducer<VectorSchemaRoot, BufferAllocator> producer, BufferAllocator allocator,
long creationTime, SetOnce<VectorSchemaRoot> root) {
record StreamProducerHolder(StreamProducer<VectorSchemaRoot, BufferAllocator> producer, BufferAllocator allocator, long creationTime,
SetOnce<VectorSchemaRoot> root) {
public StreamProducerHolder {
Objects.requireNonNull(producer, "StreamProducer cannot be null");
Objects.requireNonNull(allocator, "BufferAllocator cannot be null");
Expand Down

0 comments on commit cf1733f

Please sign in to comment.