Examples of addFragment()


Examples of com.semagia.atomico.server.storage.IModifiableStorage.addFragment()

        // Reject request iff the media type is null.
        if (mediaType == null) {
            // 415 == Unsupported Media Type
            return Response.status(415).build();
        }
        final IFragmentInfo info = storage.addFragment(_collInfo.getCollectionId(), null);
        if (info == null) {
            throw new WebApplicationException(Status.INTERNAL_SERVER_ERROR);
        }
        return Response.created(LinkUtils.linkTo(getBaseURI(), _collInfo, info))
                        .lastModified(new Date(info.getUpdated()))
View Full Code Here

Examples of org.apache.tajo.master.querymaster.QueryUnit.addFragment()

      if (event instanceof FragmentScheduleEvent) {
        FragmentScheduleEvent castEvent = (FragmentScheduleEvent) event;
        if (context.isLeafQuery()) {
          QueryUnitAttemptScheduleContext queryUnitContext = new QueryUnitAttemptScheduleContext();
          QueryUnit task = SubQuery.newEmptyQueryUnit(context, queryUnitContext, subQuery, nextTaskId++);
          task.addFragment(castEvent.getLeftFragment(), true);
          scheduledObjectNum++;
          if (castEvent.hasRightFragments()) {
            task.addFragments(castEvent.getRightFragments());
            //scheduledObjectNum += castEvent.getRightFragments().size();
          }
View Full Code Here

Examples of org.apache.tajo.master.querymaster.QueryUnit.addFragment()

        QueryUnitAttemptScheduleContext queryUnitContext = new QueryUnitAttemptScheduleContext();
        QueryUnit task = SubQuery.newEmptyQueryUnit(context, queryUnitContext, subQuery, nextTaskId++);
        scheduledObjectNum++;
        for (Entry<String, List<URI>> eachFetch : fetches.entrySet()) {
          task.addFetches(eachFetch.getKey(), eachFetch.getValue());
          task.addFragment(fragmentsForNonLeafTask[0], true);
          if (fragmentsForNonLeafTask[1] != null) {
            task.addFragment(fragmentsForNonLeafTask[1], true);
          }
        }
        subQuery.getEventHandler().handle(new TaskEvent(task.getId(), TaskEventType.T_SCHEDULE));
View Full Code Here

Examples of org.apache.tajo.master.querymaster.QueryUnit.addFragment()

        scheduledObjectNum++;
        for (Entry<String, List<URI>> eachFetch : fetches.entrySet()) {
          task.addFetches(eachFetch.getKey(), eachFetch.getValue());
          task.addFragment(fragmentsForNonLeafTask[0], true);
          if (fragmentsForNonLeafTask[1] != null) {
            task.addFragment(fragmentsForNonLeafTask[1], true);
          }
        }
        subQuery.getEventHandler().handle(new TaskEvent(task.getId(), TaskEventType.T_SCHEDULE));
      } else if (event instanceof QueryUnitAttemptScheduleEvent) {
        QueryUnitAttemptScheduleEvent castEvent = (QueryUnitAttemptScheduleEvent) event;
View Full Code Here

Examples of org.exoplatform.portal.config.model.PageNavigation.addFragment()

            next = navigator.sibling();
            if (next == Element.PAGE_NODES) {
                for (StaxNavigator<Element> fork : navigator.fork(Element.PAGE_NODES)) {
                    NavigationFragment fragment = new NavigationFragment();
                    navigation.addFragment(fragment);

                    next = fork.child();
                    if (next == Element.PARENT_URI) {
                        String parentUri = fork.getContent();
                        if (parentUri == null) {
View Full Code Here

Examples of org.exoplatform.portal.config.model.PageNavigation.addFragment()

            children.add(createPageNode(service, childNode));
        }

        NavigationFragment fragment = new NavigationFragment();
        fragment.setNodes(children);
        pageNavigation.addFragment(fragment);

        return pageNavigation;
    }

    private static PageNavigation createFragmentedPageNavigation(DescriptionService service, NavigationContext navigation,
View Full Code Here

Examples of org.exoplatform.portal.config.model.PageNavigation.addFragment()

        StringBuilder parentUri = new StringBuilder("");
        getPath(node.getParent(), parentUri);
        fragment.setParentURI(parentUri.toString());
        fragment.setNodes(children);

        pageNavigation.addFragment(fragment);

        return pageNavigation;
    }

    private static void getPath(NodeContext<NodeContext<?>> node, StringBuilder parentUri) {
View Full Code Here

Examples of org.exoplatform.portal.config.model.PageNavigation.addFragment()

         children.add(createPageNode(service, childNode));
      }

      NavigationFragment fragment = new NavigationFragment();
      fragment.setNodes(children);
      pageNavigation.addFragment(fragment);

      return pageNavigation;
   }

   private static PageNavigation createFragmentedPageNavigation(DescriptionService service, NavigationContext navigation, NodeContext<NodeContext<?>> node)
View Full Code Here

Examples of org.exoplatform.portal.config.model.PageNavigation.addFragment()

      StringBuilder parentUri = new StringBuilder("");
      getPath(node.getParent(), parentUri);
      fragment.setParentURI(parentUri.toString());
      fragment.setNodes(children);

      pageNavigation.addFragment(fragment);

      return pageNavigation;
   }

   private static void getPath(NodeContext<NodeContext<?>> node, StringBuilder parentUri)
View Full Code Here

Examples of org.exoplatform.portal.config.model.PageNavigation.addFragment()

         if (next == Element.PAGE_NODES)
         {
            for (StaxNavigator<Element> fork: navigator.fork(Element.PAGE_NODES))
            {
               NavigationFragment fragment = new NavigationFragment();
               navigation.addFragment(fragment);

               next = fork.child();
               if (next == Element.PARENT_URI)
               {
                  String parentUri = fork.getContent();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.