This is an automated email from the ASF dual-hosted git repository.
qingwzhao pushed a change to branch paimon_store_distributed
in repository https://gitbox.apache.org/repos/asf/geaflow.git
discard fed5c252 update
omit 82e85ce6 fix ut
omit 888b2873 update
omit 6c79c2d8 fix checkstyle
omit 1e8ce905 update
omit c5f2bfd4 feat: support paimon store in distributed mode
add 66930c4d feat: ci timeout optimize (#606)
add 017893ce [MCP] Implement MCP local tools for demo case (#610)
add ce2ebf8a Jdk11 ci support (#618)
add e065ad6d [GQL] Add direction(edge) UDF for GQL (#617)
add a3b10e3f feat: support paimon store in distributed mode
add 3963e44c update
add 470961ec fix checkstyle
add c8ee468c update
add d946ee67 fix ut
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (fed5c252)
\
N -- N -- N refs/heads/paimon_store_distributed (d946ee67)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci-jdk11.yml | 68 +++++++
.github/workflows/ci.yml | 30 ++-
geaflow-console/pom.xml | 9 +-
geaflow-kubernetes-operator/pom.xml | 4 +-
geaflow-mcp/pom.xml | 71 ++++++-
.../geaflow/mcp/server/GeaFlowMcpActions.java | 16 +-
.../mcp/server/GeaFlowMcpActionsLocalImpl.java | 221 +++++++++++++++++++++
.../geaflow/mcp/server/GeaFlowMcpServer.java | 2 +
.../geaflow/mcp/server/GeaFlowMcpServerTools.java | 98 ++++++++-
.../org/apache/geaflow/mcp/server/ToolDesc.java | 64 ++++++
.../geaflow/mcp/server/util/McpConstants.java | 30 ++-
.../geaflow/mcp/server/util/McpLocalFileUtil.java | 66 ++++++
.../geaflow/mcp/server/util/QueryFormatUtil.java | 98 +++++++++
.../geaflow/mcp/server/util/QueryLocalRunner.java | 142 +++++++++++++
.../geaflow/mcp/server/GeaFlowMcpClientTest.java | 127 +++++++++++-
.../geaflow/mcp/server/util/YamlParserTest.java | 9 +-
.../src/test/resources/gql/insert1 | 3 +
.../src/test/resources/gql/insert1_error | 3 +
.../src/test/resources/gql/licenseHead | 0
.../src/test/resources/gql/modern | 11 +-
.../src/test/resources/gql/modern_error | 13 +-
.../src/test/resources/gql/query1 | 11 +-
.../geaflow/common/binary/BinaryOperations.java | 5 +-
.../apache/geaflow/common/utils/IdGenerator.java | 1 +
.../apache/geaflow/common/utils/ProcessUtil.java | 2 +-
.../geaflow/common/utils/RetryCommandTest.java | 6 +-
.../geaflow/collector/AbstractCollector.java | 6 +-
.../geaflow-engine/geaflow-rpc-proto/pom.xml | 10 +-
.../network/protocol/CompositeFileRegion.java | 1 +
.../core/protocol/AbstractExecutableCommand.java | 4 -
.../schema/function/BuildInSqlFunctionTable.java | 3 +
.../table/other/{EdgeSrcId.java => Direction.java} | 11 +-
.../apache/geaflow/dsl/util/GraphSchemaUtil.java | 5 +
geaflow/geaflow-dsl/geaflow-dsl-runtime/pom.xml | 61 ++++++
.../apache/geaflow/dsl/runtime/QueryContext.java | 4 +
.../dsl/runtime/command/CreateGraphCommand.java | 1 +
.../dsl/runtime/engine/GeaFlowRuntimeGraph.java | 2 +-
.../GeaFlowStaticVCAggTraversalFunction.java | 2 +-
.../runtime/traversal/path/AbstractTreePath.java | 2 +-
.../geaflow/dsl/runtime/query/GQLMatchTest.java | 10 +
.../src/test/resources/expect/gql_match_014.txt | 1 +
.../query/{gql_match_013.sql => gql_match_014.sql} | 7 +-
geaflow/geaflow-examples/pom.xml | 7 +-
.../example/stream/StreamWordFlatMapPipeline.java | 2 +-
.../example/stream/StreamWordPrintPipeline.java | 2 +-
.../example/window/WindowKeyAggPipeline.java | 2 +-
.../example/window/WindowStreamKeyAggPipeline.java | 2 +-
.../window/WindowStreamWordCountPipeline.java | 2 +-
.../example/window/WindowWordCountPipeline.java | 2 +-
.../infer/exchange/DataQueueInputStream.java | 3 +-
.../infer/exchange/DataQueueOutputStream.java | 3 +-
.../geaflow/infer/exchange/MemoryMapper.java | 5 +-
.../apache/geaflow/infer/exchange/UnSafeUtils.java | 13 +-
.../org/apache/geaflow/memory/DirectMemory.java | 3 +-
.../main/java/org/apache/geaflow/memory/Page.java | 3 +-
.../apache/geaflow/memory/PlatformDependent.java | 17 +-
.../apache/geaflow/memory/cleaner/CleanerTest.java | 2 +-
.../geaflow-store/geaflow-store-memory/pom.xml | 5 +
geaflow/geaflow-state/geaflow-state-common/pom.xml | 10 +-
geaflow/geaflow-state/geaflow-state-impl/pom.xml | 5 +
geaflow/geaflow-utils/pom.xml | 5 +
.../apache/geaflow/utils/keygroup/KeyGroup.java | 2 +-
.../org/apache/geaflow/utils/math/MathUtil.java | 9 +-
geaflow/pom.xml | 9 +-
pom.xml | 100 +++++++++-
tools/checkstyle.xml | 19 +-
66 files changed, 1302 insertions(+), 170 deletions(-)
create mode 100644 .github/workflows/ci-jdk11.yml
copy
geaflow-console/app/biz/shared/src/main/java/org/apache/geaflow/console/biz/shared/view/UserView.java
=>
geaflow-mcp/src/main/java/org/apache/geaflow/mcp/server/GeaFlowMcpActions.java
(72%)
create mode 100644
geaflow-mcp/src/main/java/org/apache/geaflow/mcp/server/GeaFlowMcpActionsLocalImpl.java
create mode 100644
geaflow-mcp/src/main/java/org/apache/geaflow/mcp/server/ToolDesc.java
copy
geaflow-console/app/core/service/src/main/java/org/apache/geaflow/console/core/service/llm/LLMClientFactory.java
=>
geaflow-mcp/src/main/java/org/apache/geaflow/mcp/server/util/McpConstants.java
(55%)
create mode 100644
geaflow-mcp/src/main/java/org/apache/geaflow/mcp/server/util/McpLocalFileUtil.java
create mode 100644
geaflow-mcp/src/main/java/org/apache/geaflow/mcp/server/util/QueryFormatUtil.java
create mode 100644
geaflow-mcp/src/main/java/org/apache/geaflow/mcp/server/util/QueryLocalRunner.java
copy
geaflow-console/geaflow-web/src/components/console/plug-manage/index.module.less
=> geaflow-mcp/src/test/resources/gql/insert1 (90%)
copy
geaflow-console/geaflow-web/src/components/console/plug-manage/index.module.less
=> geaflow-mcp/src/test/resources/gql/insert1_error (91%)
copy
geaflow-console/geaflow-web/src/components/console/function-manage/index.module.less
=> geaflow-mcp/src/test/resources/gql/licenseHead (100%)
copy
geaflow/geaflow-dsl/geaflow-dsl-runtime/src/test/resources/query/gql_graph_write_003.sql
=> geaflow-mcp/src/test/resources/gql/modern (89%)
copy
geaflow/geaflow-dsl/geaflow-dsl-runtime/src/test/resources/query/gql_graph_write_003.sql
=> geaflow-mcp/src/test/resources/gql/modern_error (88%)
copy
geaflow/geaflow-dsl/geaflow-dsl-runtime/src/test/resources/query/values_002.sql
=> geaflow-mcp/src/test/resources/gql/query1 (85%)
copy
geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/other/{EdgeSrcId.java
=> Direction.java} (78%)
create mode 100644
geaflow/geaflow-dsl/geaflow-dsl-runtime/src/test/resources/expect/gql_match_014.txt
copy
geaflow/geaflow-dsl/geaflow-dsl-runtime/src/test/resources/query/{gql_match_013.sql
=> gql_match_014.sql} (87%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
